You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 20:12:36 UTC
[19/50] [abbrv] incubator-apex-malhar git commit: Merge branch
'kafka-maxbytes' of https://github.com/PramodSSImmaneni/incubator-apex-malhar
into devel-3
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 <hs...@apache.org>
Authored: Wed Dec 30 08:34:23 2015 -0800
Committer: Siyuan Hua <hs...@apache.org>
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(-)
----------------------------------------------------------------------