KafkaProducerTopology (Storm 2.7.1 API)

java.lang.Object
- org.apache.storm.kafka.bolt.KafkaProducerTopology

public class KafkaProducerTopology
extends Object

Constructor Summary

Constructors
Constructor Description

KafkaProducerTopology()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static StormTopology`	`newTopology(String brokerUrl, String topicName)`	Create a new topology that writes random UUIDs to Kafka.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - KafkaProducerTopology
```
public KafkaProducerTopology()
```
- Method Detail
  - newTopology
```
public static StormTopology newTopology(String brokerUrl,
                                        String topicName)
```
    Create 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 LambdaSpout and uses a KafkaBolt to publish the UUIDs to the kafka topic specified