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) |
run
public TridentKafkaClientTopologyWildcardTopics()
protected KafkaTridentSpoutConfig<String,String> newKafkaSpoutConfig(String bootstrapServers)
newKafkaSpoutConfig
in class TridentKafkaClientTopologyNamedTopics
Copyright © 2020 The Apache Software Foundation. All rights reserved.