Package org.apache.storm.kafka.trident
Class TridentKafkaConsumerTopology
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaConsumerTopology
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormTopologynewTopology(ITridentDataSource tridentSpout) Creates a new topology that prints inputs to stdout.
- 
Field Details- 
LOGprotected static final org.slf4j.Logger LOG
 
- 
- 
Constructor Details- 
TridentKafkaConsumerTopologypublic TridentKafkaConsumerTopology()
 
- 
- 
Method Details- 
newTopologyCreates a new topology that prints inputs to stdout.- Parameters:
- tridentSpout- The spout to use
 
 
-