Package org.apache.storm.kafka.trident
Class TridentKafkaClientTopologyNamedTopics
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaClientTopologyNamedTopics
- Direct Known Subclasses:
- TridentKafkaClientTopologyWildcardTopics
This example sets up a few topologies to put random strings in Kafka topics via the KafkaBolt,
 and shows how to set up a Trident topology that reads from some Kafka topics using the KafkaSpout.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidprotected KafkaTridentSpoutConfig<String,String> newKafkaSpoutConfig(String bootstrapServers) protected void
- 
Constructor Details- 
TridentKafkaClientTopologyNamedTopicspublic TridentKafkaClientTopologyNamedTopics()
 
- 
- 
Method Details- 
newKafkaSpoutConfig
- 
main- Throws:
- Exception
 
- 
runprotected void run(String[] args) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, InterruptedException 
 
-