public interface TopicFilter extends Serializable
| Modifier and Type | Method and Description |
|---|---|
Set<org.apache.kafka.common.TopicPartition> |
getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Get the Kafka TopicPartitions subscribed to by this set of spouts.
|
String |
getTopicsString()
Get the topics string.
|
Set<org.apache.kafka.common.TopicPartition> getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Get the Kafka TopicPartitions subscribed to by this set of spouts.
consumer - The Kafka consumer to use to read the list of existing partitionsString getTopicsString()
Get the topics string.
Copyright © 2021 The Apache Software Foundation. All rights reserved.