public static class TopicPartitionFilter.CompositeTopicPartitionFilter extends Object implements TopicPartitionFilter
TopicPartitionFilter.CompositeTopicPartitionFilter, TopicPartitionFilter.TopicFilterAndPartitionFilter
Constructor and Description |
---|
CompositeTopicPartitionFilter(List<TopicPartitionFilter> filters) |
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.
|
public CompositeTopicPartitionFilter(List<TopicPartitionFilter> filters)
public boolean isTopicAllowed(String topic)
TopicPartitionFilter
isTopicAllowed
in interface TopicPartitionFilter
public boolean isTopicPartitionAllowed(org.apache.kafka.common.TopicPartition partition)
TopicPartitionFilter
isTopicPartitionAllowed
in interface TopicPartitionFilter