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, runMain
public KafkaSpoutTopologyMainWildcardTopics()
protected StormTopology getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)
getTopologyKafkaSpout
in class KafkaSpoutTopologyMainNamedTopics
protected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers)
getKafkaSpoutConfig
in class KafkaSpoutTopologyMainNamedTopics
Copyright © 2022 The Apache Software Foundation. All rights reserved.