Name | Description | Type | Package | Framework |
DefaultTopicSelector | Class | storm.kafka.bolt.selector | Apache Storm | |
FieldNameBasedTupleToKafkaMapper | Class | storm.kafka.bolt.mapper | Apache Storm | |
KafkaBolt | Bolt implementation that can send Tuple data to Kafka It expects the producer configuration and topic in storm config under | Class | storm.kafka.bolt | Apache Storm |
KafkaTopicSelector | Interface | storm.kafka.bolt.selector | Apache Storm | |
TupleToKafkaMapper | as the really verbose name suggests this interface mapps a storm tuple to kafka key and message. | Interface | storm.kafka.bolt.mapper | Apache Storm |