Class TridentKafkaConsumerTopology

java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaConsumerTopology

public class TridentKafkaConsumerTopology extends Object
  • Field Details

    • LOG

      protected static final org.slf4j.Logger LOG
  • Constructor Details

    • TridentKafkaConsumerTopology

      public TridentKafkaConsumerTopology()
  • Method Details

    • newTopology

      public static StormTopology newTopology(ITridentDataSource tridentSpout)
      Creates a new topology that prints inputs to stdout.
      Parameters:
      tridentSpout - The spout to use