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/07/14 23:24:10 UTC
[2/2] apex-malhar git commit: Merge branch 'APEXMALHAR-2086' of
github.com:sandeshh/apex-malhar
Merge branch 'APEXMALHAR-2086' of github.com:sandeshh/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/13201282
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/13201282
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/13201282
Branch: refs/heads/master
Commit: 13201282338f2a43d1ca416165a85cbfb804762e
Parents: 2397038 0444ced
Author: Siyuan Hua <hs...@apache.org>
Authored: Thu Jul 14 16:23:45 2016 -0700
Committer: Siyuan Hua <hs...@apache.org>
Committed: Thu Jul 14 16:23:45 2016 -0700
----------------------------------------------------------------------
.../kafka/AbstractKafkaOutputOperator.java | 122 ++++++
...afkaSinglePortExactlyOnceOutputOperator.java | 401 +++++++++++++++++++
.../kafka/KafkaSinglePortOutputOperator.java | 43 ++
.../malhar/kafka/KafkaOutputOperatorTest.java | 375 +++++++++++++++++
kafka/src/test/resources/log4j.properties | 5 +-
5 files changed, 944 insertions(+), 2 deletions(-)
----------------------------------------------------------------------