Package org.apache.storm.kafka.spout
Class KafkaSpoutTopologyMainWildcardTopics
java.lang.Object
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainWildcardTopics
This example is similar to 
KafkaSpoutTopologyMainNamedTopics, but demonstrates subscribing to Kafka topics with a regex.- 
Field SummaryFields inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopicsTOPIC_0, TOPIC_1, TOPIC_2
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers) protected StormTopologygetTopologyKafkaSpout(KafkaSpoutConfig<String, String> spoutConfig) static voidMethods inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopicsgetConfig, getRetryService, runMain
- 
Constructor Details- 
KafkaSpoutTopologyMainWildcardTopicspublic KafkaSpoutTopologyMainWildcardTopics()
 
- 
- 
Method Details- 
main- Throws:
- Exception
 
- 
getTopologyKafkaSpout- Overrides:
- getTopologyKafkaSpoutin class- KafkaSpoutTopologyMainNamedTopics
 
- 
getKafkaSpoutConfig- Overrides:
- getKafkaSpoutConfigin class- KafkaSpoutTopologyMainNamedTopics
 
 
-