@Internal public class KafkaTopicsDescriptor extends Object implements Serializable
Constructor and Description |
---|
KafkaTopicsDescriptor(List<String> fixedTopics,
Pattern topicPattern) |
Modifier and Type | Method and Description |
---|---|
List<String> |
getFixedTopics() |
boolean |
isFixedTopics() |
boolean |
isMatchingTopic(String topic)
Check if the input topic matches the topics described by this KafkaTopicDescriptor.
|
boolean |
isTopicPattern() |
String |
toString() |
public boolean isFixedTopics()
public boolean isTopicPattern()
public boolean isMatchingTopic(String topic)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.