Package org.apache.storm.kafka.bolt.mapper

Interface TupleToKafkaMapper<K,V>

Type Parameters:
K - type of key.
V - type of value.
All Superinterfaces:
Serializable
All Known Implementing Classes:
FieldNameBasedTupleToKafkaMapper
public interface TupleToKafkaMapper<K,V> extends Serializable
Interface defining a mapping from storm tuple to kafka key and message.

  • Method Details

    • getKeyFromTuple

      K getKeyFromTuple(Tuple tuple)

    • getMessageFromTuple

      V getMessageFromTuple(Tuple tuple)