org.apache.flink.streaming.connectors.kafka.internals

Class KafkaTopicsDescriptor

java.lang.Object

org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicsDescriptor

All Implemented Interfaces:

Serializable

@Internal
public class KafkaTopicsDescriptor
extends Object
implements Serializable

A Kafka Topics Descriptor describes how the consumer subscribes to Kafka topics - either a fixed list of topics, or a topic pattern.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaTopicsDescriptor(List<String> fixedTopics, Pattern topicPattern)

Method Summary

Modifier and Type	Method and Description
List<String>	getFixedTopics()
Pattern	getTopicPattern()
boolean	isFixedTopics()
boolean	isTopicPattern()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaTopicsDescriptor

public KafkaTopicsDescriptor(@Nullable
                             List<String> fixedTopics,
                             @Nullable
                             Pattern topicPattern)

Method Detail

isFixedTopics

public boolean isFixedTopics()

isTopicPattern

public boolean isTopicPattern()

getFixedTopics

public List<String> getFixedTopics()

getTopicPattern

public Pattern getTopicPattern()

toString

public String toString()

Overrides:

toString in class Object