storm.kafka.bolt
Class KafkaBolt<K,V>
java.lang.Object
backtype.storm.topology.base.BaseComponent
backtype.storm.topology.base.BaseRichBolt
storm.kafka.bolt.KafkaBolt<K,V>
- All Implemented Interfaces:
- IBolt, IComponent, IRichBolt, Serializable
public class KafkaBolt<K,V>
- extends BaseRichBolt
Bolt implementation that can send Tuple data to Kafka
It expects the producer configuration and topic in storm config under
'kafka.broker.properties' and 'topic'
respectively.
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TOPIC
public static final String TOPIC
- See Also:
- Constant Field Values
KAFKA_BROKER_PROPERTIES
public static final String KAFKA_BROKER_PROPERTIES
- See Also:
- Constant Field Values
KafkaBolt
public KafkaBolt()
withTupleToKafkaMapper
public KafkaBolt<K,V> withTupleToKafkaMapper(TupleToKafkaMapper<K,V> mapper)
withTopicSelector
public KafkaBolt<K,V> withTopicSelector(KafkaTopicSelector selector)
prepare
public void prepare(Map stormConf,
TopologyContext context,
OutputCollector collector)
execute
public void execute(Tuple input)
declareOutputFields
public void declareOutputFields(OutputFieldsDeclarer declarer)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.