DataTorrent/Malhar — pull request #1105 by siyuanh (2014-10-02 02:23:58+00:00)
Title: Big kafka consumer change

MLHR-1471 #resolve #comment force close kafka connection

MLHR-1439 #resolve #comment use single thread to refresh the metadata

Other minor change:
1. Close the BenchmarkProducer in periodical producing mode
2. Make consumer bufferSize configurable
3. Set to repartition*Interval < 0 to make one_to_many none repartitionable