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 <[email protected]> Authored: Thu Jul 14 16:23:45 2016 -0700 Committer: Siyuan Hua <[email protected]> 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(-) ----------------------------------------------------------------------
