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 and 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(KafkaTopicSelector selector)
KafkaBolt<K,V>	KafkaBolt.withTopicSelector(String topic) Set the messages to be published to a single topic.
KafkaBolt<K,V>	KafkaBolt.withTupleToKafkaMapper(TupleToKafkaMapper<K,V> mapper)