Merge branch 'APEXMALHAR-2121-kafka-emit-update' of github.com:DT-Priyanka/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/719cf952 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/719cf952 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/719cf952 Branch: refs/heads/master Commit: 719cf952deb3b04c790ac3155f108965bed70b6b Parents: 4512508 dc82184 Author: Siyuan Hua <[email protected]> Authored: Wed Jun 22 17:38:23 2016 -0700 Committer: Siyuan Hua <[email protected]> Committed: Wed Jun 22 17:38:23 2016 -0700 ---------------------------------------------------------------------- .../contrib/kafka/AbstractKafkaInputOperator.java | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
