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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
protected KafkaTridentSpoutConfig<String,
String> newKafkaSpoutConfig
(String bootstrapServers) Methods inherited from class org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
run
-
Constructor Details
-
TridentKafkaClientTopologyWildcardTopics
public TridentKafkaClientTopologyWildcardTopics()
-
-
Method Details
-
newKafkaSpoutConfig
- Overrides:
newKafkaSpoutConfig
in classTridentKafkaClientTopologyNamedTopics
-
main
- Throws:
Exception
-