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 © 2021 The Apache Software Foundation. All rights reserved.