org.apache.storm.kafka.bolt

Class KafkaProducerTopology

java.lang.Object

org.apache.storm.kafka.bolt.KafkaProducerTopology

public class KafkaProducerTopology
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaProducerTopology()

Method Summary

Modifier and Type	Method and 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