Merge branch 'kafka-maxbytes' of https://github.com/PramodSSImmaneni/incubator-apex-malhar into devel-3
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/935a4970 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/935a4970 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/935a4970 Branch: refs/heads/master Commit: 935a49706e4cd8933820eadf6baf31d2e37faa4d Parents: 3a8aaba 326db94 Author: Siyuan Hua <[email protected]> Authored: Wed Dec 30 08:34:23 2015 -0800 Committer: Siyuan Hua <[email protected]> Committed: Wed Dec 30 08:34:23 2015 -0800 ---------------------------------------------------------------------- .../kafka/AbstractKafkaInputOperator.java | 88 ++++++++++++++------ .../contrib/kafka/KafkaConsumer.java | 30 +++---- .../contrib/kafka/KafkaInputOperatorTest.java | 76 ++++++++++++++--- 3 files changed, 140 insertions(+), 54 deletions(-) ----------------------------------------------------------------------
