org.apache.storm.kafka.trident

Class KafkaProducerTopology

java.lang.Object

org.apache.storm.kafka.trident.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)

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)

Parameters:

brokerUrl - Kafka broker URL

topicName - Topic to which publish sentences

Returns:

A Storm topology that produces random sentences using RandomSentenceSpout and uses a KafkaBolt to publish the sentences to the kafka topic specified