DataTorrent/Malhar — pull request #1119 by siyuanh (2014-10-08 02:47:02+00:00)
Title: Implement counters for kafka input operator

Add brokerid, brokerhost,(new java bean per partition) connection num to KafkaMeterStats
Add KafkaMeterStatsAggregator for aggregation of kafka stats
Change msg/s, bytes/s from double to long
Reuse producer in KafkaOutputBenchmark application