Class | Description |
---|---|
KafkaBolt<K,V> |
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.
|
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.