Package 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	Description
KafkaProducerTopology()

Method Summary

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 Details

KafkaProducerTopology

public KafkaProducerTopology()

Method Details

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