Uses of Class
org.apache.storm.kafka.bolt.KafkaBolt
-
Uses of KafkaBolt in org.apache.storm.kafka.bolt
Modifier and TypeMethodDescriptionKafkaBolt.withProducerCallback
(PreparableCallback producerCallback) Sets a user defined callback for use with the KafkaProducer.KafkaBolt.withProducerProperties
(Properties producerProperties) KafkaBolt.withTopicSelector
(String topic) Set the messages to be published to a single topic.KafkaBolt.withTopicSelector
(KafkaTopicSelector selector) KafkaBolt.withTupleToKafkaMapper
(TupleToKafkaMapper<K, V> mapper)