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 and Description
String	getTopic(Tuple tuple)

Method Detail

getTopic

String getTopic(Tuple tuple)