- 
Method Summary
Set<org.apache.kafka.common.TopicPartition>
Get the Kafka TopicPartitions subscribed to by this set of spouts. 
 
 
 
 
- 
Method Details
- 
getAllSubscribedPartitionsSet<org.apache.kafka.common.TopicPartition> getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer) Get the Kafka TopicPartitions subscribed to by this set of spouts. 
- Parameters:
- consumer- The Kafka consumer to use to read the list of existing partitions
- Returns:
- The Kafka partitions this set of spouts should subscribe to
 
- 
getTopicsStringGet the topics string. 
- Returns:
- A human-readable string representing the topics that pass the filter.