Merge branch 'release-3.1' of https://github.com/siyuanh/incubator-apex-malhar into release-3.1
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/9cc62db3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/9cc62db3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/9cc62db3 Branch: refs/heads/release-3.1 Commit: 9cc62db3d5a346fed0ddf12d735c61836988f29d Parents: 2bf83a8 794ece4 Author: Thomas Weise <[email protected]> Authored: Thu Dec 10 13:01:25 2015 -0800 Committer: Thomas Weise <[email protected]> Committed: Thu Dec 10 13:01:25 2015 -0800 ---------------------------------------------------------------------- .../contrib/kafka/SimpleKafkaConsumer.java | 14 ++++++- .../contrib/kafka/OffsetManagerTest.java | 41 ++++++++++++++++---- 2 files changed, 45 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
