public class TridentKafkaClientWordCountWildcardTopics extends TridentKafkaClientWordCountNamedTopics
Constructor and Description |
---|
TridentKafkaClientWordCountWildcardTopics() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
protected KafkaSpoutConfig<String,String> |
newKafkaSpoutConfig() |
newRetryService, run
public TridentKafkaClientWordCountWildcardTopics()
protected KafkaSpoutConfig<String,String> newKafkaSpoutConfig()
newKafkaSpoutConfig
in class TridentKafkaClientWordCountNamedTopics
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.