org.apache.storm.kafka.trident

Class TridentKafkaClientWordCountWildcardTopics

java.lang.Object

org.apache.storm.kafka.trident.TridentKafkaClientWordCountNamedTopics

org.apache.storm.kafka.trident.TridentKafkaClientWordCountWildcardTopics

public class TridentKafkaClientWordCountWildcardTopics
extends TridentKafkaClientWordCountNamedTopics

Constructor Summary

Constructors

Constructor and Description
TridentKafkaClientWordCountWildcardTopics()

Method Summary

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

Methods inherited from class org.apache.storm.kafka.trident.TridentKafkaClientWordCountNamedTopics

newRetryService, run

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentKafkaClientWordCountWildcardTopics

public TridentKafkaClientWordCountWildcardTopics()

Method Detail

newKafkaSpoutConfig

protected KafkaSpoutConfig<String,String> newKafkaSpoutConfig()

Overrides:

newKafkaSpoutConfig in class TridentKafkaClientWordCountNamedTopics

main

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

Throws:

Exception