public interface TopicPartitionFilter
Modifier and Type | Interface and Description |
---|---|
static class |
TopicPartitionFilter.CompositeTopicPartitionFilter |
static class |
TopicPartitionFilter.TopicFilterAndPartitionFilter |
Modifier and Type | Method and Description |
---|---|
boolean |
isTopicAllowed(String topic)
Used to filter topics based on a certain criteria, for example, a set of topic names or a regular expression.
|
boolean |
isTopicPartitionAllowed(org.apache.kafka.common.TopicPartition partition)
Used to filter topic-partitions based on a certain criteria, for example, a topic pattern and a set of partition ids.
|
boolean isTopicAllowed(String topic)
boolean isTopicPartitionAllowed(org.apache.kafka.common.TopicPartition partition)