public class KafkaSpoutTopologyMainWildcardTopics extends KafkaSpoutTopologyMainNamedTopics
This example is similar to KafkaSpoutTopologyMainNamedTopics, but demonstrates subscribing to Kafka topics with a regex.
TOPIC_0, TOPIC_1, TOPIC_2| Constructor and Description |
|---|
KafkaSpoutTopologyMainWildcardTopics() |
| Modifier and Type | Method and Description |
|---|---|
protected KafkaSpoutConfig<String,String> |
getKafkaSpoutConfig(String bootstrapServers) |
protected StormTopology |
getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig) |
static void |
main(String[] args) |
getConfig, getRetryService, runMainpublic KafkaSpoutTopologyMainWildcardTopics()
protected StormTopology getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)
getTopologyKafkaSpout in class KafkaSpoutTopologyMainNamedTopicsprotected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers)
getKafkaSpoutConfig in class KafkaSpoutTopologyMainNamedTopicsCopyright © 2021 The Apache Software Foundation. All rights reserved.