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 Detail

      • getKeyFromTuple

        K getKeyFromTuple​(Tuple tuple)

      • getMessageFromTuple

        V getMessageFromTuple​(Tuple tuple)