Package org.apache.storm.kafka.trident
Class TridentKafkaClientTopologyWildcardTopics
- java.lang.Object
-
- org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
-
- org.apache.storm.kafka.trident.TridentKafkaClientTopologyWildcardTopics
-
public class TridentKafkaClientTopologyWildcardTopics extends TridentKafkaClientTopologyNamedTopics
This example is similar toTridentKafkaClientTopologyWildcardTopics
, but demonstrates subscribing to Kafka topics with a regex.
-
-
Constructor Summary
Constructors Constructor Description TridentKafkaClientTopologyWildcardTopics()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static void
main(String[] args)
protected KafkaTridentSpoutConfig<String,String>
newKafkaSpoutConfig(String bootstrapServers)
-
Methods inherited from class org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
run
-
-
-
-
Method Detail
-
newKafkaSpoutConfig
protected KafkaTridentSpoutConfig<String,String> newKafkaSpoutConfig(String bootstrapServers)
- Overrides:
newKafkaSpoutConfig
in classTridentKafkaClientTopologyNamedTopics
-
-