DataTorrent/Malhar — pull request #149 by siyuanh (2013-10-16 01:32:13+00:00)
Title: Checkpoint consumer offset  #146

Checkpoint consumer offset #146 otherwise, recovered consumer will read msg from very beginning