Class KafkaClientHdfsTopo

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

public class KafkaClientHdfsTopo extends Object
This topo helps measure speed of reading from Kafka and writing to Hdfs.

Spout Reads from Kafka.

Bolt writes to Hdfs.