Package org.apache.storm.kafka.bolt
Class KafkaProducerTopology
java.lang.Object
org.apache.storm.kafka.bolt.KafkaProducerTopology
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormTopologynewTopology(String brokerUrl, String topicName) Create a new topology that writes random UUIDs to Kafka.
- 
Constructor Details- 
KafkaProducerTopologypublic KafkaProducerTopology()
 
- 
- 
Method Details- 
newTopologyCreate a new topology that writes random UUIDs to Kafka.- Parameters:
- brokerUrl- Kafka broker URL
- topicName- Topic to which publish sentences
- Returns:
- A Storm topology that produces random UUIDs using a LambdaSpoutand uses aKafkaBoltto publish the UUIDs to the kafka topic specified
 
 
-