Package org.apache.storm.kafka.trident
Class TridentKafkaClientTopologyWildcardTopics
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
org.apache.storm.kafka.trident.TridentKafkaClientTopologyWildcardTopics
This example is similar to 
TridentKafkaClientTopologyWildcardTopics, but demonstrates subscribing to Kafka topics with a regex.- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidprotected KafkaTridentSpoutConfig<String,String> newKafkaSpoutConfig(String bootstrapServers) Methods inherited from class org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopicsrun
- 
Constructor Details- 
TridentKafkaClientTopologyWildcardTopicspublic TridentKafkaClientTopologyWildcardTopics()
 
- 
- 
Method Details- 
newKafkaSpoutConfig- Overrides:
- newKafkaSpoutConfigin class- TridentKafkaClientTopologyNamedTopics
 
- 
main- Throws:
- Exception
 
 
-