Class FieldIndexTopicSelector
java.lang.Object
org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector
- All Implemented Interfaces:
Serializable,KafkaTopicSelector
Uses field with a given index to select the topic name from a tuple .
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionFieldIndexTopicSelector(int fieldIndex, String defaultTopicName) Creates a new FieldIndexTopicSelector. -
Method Summary
-
Constructor Details
-
FieldIndexTopicSelector
Creates a new FieldIndexTopicSelector.- Parameters:
fieldIndex- The index of the field containing the topic namedefaultTopicName- The default topic name if the topic name cannot be read from the tuple
-
-
Method Details
-
getTopic
- Specified by:
getTopicin interfaceKafkaTopicSelector
-