Class KafkaClientSpoutNullBoltTopo

java.lang.Object
org.apache.storm.perf.KafkaClientSpoutNullBoltTopo

public class KafkaClientSpoutNullBoltTopo extends Object
Benchmark topology for measuring spout read/emit/ack performance. The spout reads and emits tuples. The bolt acks and discards received tuples.