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