DataTorrent/Malhar — pull request #1136 by siyuanh (2014-10-16 01:08:58+00:00)
Title: Add unit test and fix the OffsetManager bug in Kafka ONE_TO_MANY, partitionable input operator

partitionable input operator scenario