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 Summary
Fields inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
TOPIC_0, TOPIC_1, TOPIC_2 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers) protected StormTopologygetTopologyKafkaSpout(KafkaSpoutConfig<String, String> spoutConfig) static voidMethods inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
getConfig, getRetryService, runMain
-
Constructor Details
-
KafkaSpoutTopologyMainWildcardTopics
public KafkaSpoutTopologyMainWildcardTopics()
-
-
Method Details
-
main
- Throws:
Exception
-
getTopologyKafkaSpout
- Overrides:
getTopologyKafkaSpoutin classKafkaSpoutTopologyMainNamedTopics
-
getKafkaSpoutConfig
- Overrides:
getKafkaSpoutConfigin classKafkaSpoutTopologyMainNamedTopics
-