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
ConstructorDescriptionFieldIndexTopicSelector
(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:
getTopic
in interfaceKafkaTopicSelector
-