Package org.apache.storm.kafka.bolt.selector

Interface KafkaTopicSelector

All Superinterfaces:
Serializable
All Known Implementing Classes:
DefaultTopicSelector, FieldIndexTopicSelector, FieldNameTopicSelector
public interface KafkaTopicSelector extends Serializable

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getTopic(Tuple tuple)
     

  • Method Details