public class TridentKafkaClientTopologyWildcardTopics extends TridentKafkaClientTopologyNamedTopics
This example is similar to TridentKafkaClientTopologyWildcardTopics, but demonstrates subscribing to Kafka topics with a regex.
| Constructor and Description | 
|---|
| TridentKafkaClientTopologyWildcardTopics() | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | main(String[] args) | 
| protected KafkaTridentSpoutConfig<String,String> | newKafkaSpoutConfig(String bootstrapServers) | 
runpublic TridentKafkaClientTopologyWildcardTopics()
protected KafkaTridentSpoutConfig<String,String> newKafkaSpoutConfig(String bootstrapServers)
newKafkaSpoutConfig in class TridentKafkaClientTopologyNamedTopicsCopyright © 2022 The Apache Software Foundation. All rights reserved.