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 <[email protected]> Authored: Fri Jun 24 14:29:38 2016 -0700 Committer: Siyuan Hua <[email protected]> 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(-) ----------------------------------------------------------------------
