Package org.apache.storm.kafka.bolt.selector
-
Interface Summary Interface Description KafkaTopicSelector -
Class Summary Class Description DefaultTopicSelector FieldIndexTopicSelector Uses field with a given index to select the topic name from a tuple .FieldNameTopicSelector Uses field name to select topic name from tuple .