public class KafkaProducerTopology extends Object
Constructor and Description |
---|
KafkaProducerTopology() |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
newTopology(String brokerUrl,
String topicName)
Create a new topology that writes random UUIDs to Kafka.
|
public static StormTopology newTopology(String brokerUrl, String topicName)
Create a new topology that writes random UUIDs to Kafka.
brokerUrl
- Kafka broker URLtopicName
- Topic to which publish sentencesLambdaSpout
and uses a KafkaBolt
to publish the UUIDs to the kafka topic specifiedCopyright © 2022 The Apache Software Foundation. All rights reserved.