public interface TopicFilter extends Serializable
Modifier and Type | Method and Description |
---|---|
List<org.apache.kafka.common.TopicPartition> |
getFilteredTopicPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer)
Get the Kafka TopicPartitions passed by this filter.
|
String |
getTopicsString() |
List<org.apache.kafka.common.TopicPartition> getFilteredTopicPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer)
Get the Kafka TopicPartitions passed by this filter.
consumer
- The Kafka consumer to use to read the list of existing partitionsString getTopicsString()
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.