DataTorrent/Malhar — pull request #305 by siyuanh (2013-11-14 20:19:33+00:00)
Title: Fix github 278 and 283

1 Fix simple kafka consumer performance bug #278
2 Use Yammer metric to monitor the throughput of the consumer #283
3 Refine the kafka broker monitor thread (use ScheduledService and give
a name for the thread) #278