Package org.apache.storm.kafka.bolt
Class KafkaProducerTopology
java.lang.Object
org.apache.storm.kafka.bolt.KafkaProducerTopology
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
newTopology
(String brokerUrl, String topicName) Create a new topology that writes random UUIDs to Kafka.
-
Constructor Details
-
KafkaProducerTopology
public KafkaProducerTopology()
-
-
Method Details
-
newTopology
Create a new topology that writes random UUIDs to Kafka.- Parameters:
brokerUrl
- Kafka broker URLtopicName
- Topic to which publish sentences- Returns:
- A Storm topology that produces random UUIDs using a
LambdaSpout
and uses aKafkaBolt
to publish the UUIDs to the kafka topic specified
-