org.apache.storm.kafka.trident

Class TridentKafkaClientWordCountNamedTopics

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaClientWordCountNamedTopics

Direct Known Subclasses:

TridentKafkaClientWordCountWildcardTopics

public class TridentKafkaClientWordCountNamedTopics
extends Object

Constructor Summary

Constructors

Constructor and Description
TridentKafkaClientWordCountNamedTopics()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
protected KafkaSpoutConfig<String,String>	newKafkaSpoutConfig()
protected KafkaSpoutRetryService	newRetryService()
protected void	run(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentKafkaClientWordCountNamedTopics

public TridentKafkaClientWordCountNamedTopics()

Method Detail

newKafkaSpoutConfig

protected KafkaSpoutConfig<String,String> newKafkaSpoutConfig()

newRetryService

protected KafkaSpoutRetryService newRetryService()

main

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

Throws:

Exception

run

protected void run(String[] args)
            throws AlreadyAliveException,
                   InvalidTopologyException,
                   AuthorizationException,
                   InterruptedException

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

InterruptedException