Package org.apache.storm.kafka.spout
Class KafkaSpoutTopologyMainWildcardTopics
- java.lang.Object
-
- org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
-
- org.apache.storm.kafka.spout.KafkaSpoutTopologyMainWildcardTopics
-
public class KafkaSpoutTopologyMainWildcardTopics extends KafkaSpoutTopologyMainNamedTopics
This example is similar toKafkaSpoutTopologyMainNamedTopics
, 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 Constructor Description KafkaSpoutTopologyMainWildcardTopics()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected KafkaSpoutConfig<String,String>
getKafkaSpoutConfig(String bootstrapServers)
protected StormTopology
getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)
static void
main(String[] args)
-
Methods inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
getConfig, getRetryService, runMain
-
-
-
-
Method Detail
-
getTopologyKafkaSpout
protected StormTopology getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)
- Overrides:
getTopologyKafkaSpout
in classKafkaSpoutTopologyMainNamedTopics
-
getKafkaSpoutConfig
protected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers)
- Overrides:
getKafkaSpoutConfig
in classKafkaSpoutTopologyMainNamedTopics
-
-