org.apache.storm.kafka.trident

Class TridentKafkaTopology

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaTopology

public class TridentKafkaTopology
extends Object

Constructor Summary

Constructors

Constructor and Description
TridentKafkaTopology()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args) To run this topology ensure you have a kafka broker running and provide connection string to broker as argument.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TridentKafkaTopology

public TridentKafkaTopology()

Method Detail

main

public static void main(String[] args)
                 throws Exception

To run this topology ensure you have a kafka broker running and provide connection string to broker as argument. Create a topic test with command line, kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partition 1 –topic test

run this program and run the kafka consumer: kafka-console-consumer.sh –zookeeper localhost:2181 –topic test –from-beginning

you should see the messages flowing through.

Parameters:

args -

Throws:

Exception