Package org.apache.storm.kafka.trident.selector

Interface KafkaTopicSelector

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

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getTopic(TridentTuple tuple)