You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by hs...@apache.org on 2016/06/24 21:30:12 UTC
[2/2] apex-malhar git commit: Merge branch 'APEXMALHAR-2120' of
github.com:brightchen/incubator-apex-malhar
Merge branch 'APEXMALHAR-2120' of github.com:brightchen/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/389a2d56
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/389a2d56
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/389a2d56
Branch: refs/heads/master
Commit: 389a2d564d45f52ff26362b4a2d55ea51420671b
Parents: 719cf95 f2b7a85
Author: Siyuan Hua <hs...@apache.org>
Authored: Fri Jun 24 14:29:38 2016 -0700
Committer: Siyuan Hua <hs...@apache.org>
Committed: Fri Jun 24 14:29:38 2016 -0700
----------------------------------------------------------------------
.../malhar/kafka/AbstractKafkaPartitioner.java | 39 ++-
.../apex/malhar/kafka/KafkaConsumerWrapper.java | 58 ++---
.../malhar/kafka/KafkaInputOperatorTest.java | 237 +++++++++++++------
.../apex/malhar/kafka/KafkaTestProducer.java | 54 +++--
kafka/src/test/resources/log4j.properties | 49 ++++
5 files changed, 302 insertions(+), 135 deletions(-)
----------------------------------------------------------------------