Merge branch 'APEXMALHAR-2148' of https://github.com/siyuanh/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/e44caa5a Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/e44caa5a Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/e44caa5a Branch: refs/heads/master Commit: e44caa5a50f3d5e92c44e4f256992a3851a7a5e8 Parents: ef42c52 1339441 Author: Thomas Weise <[email protected]> Authored: Tue Aug 23 15:01:02 2016 -0700 Committer: Thomas Weise <[email protected]> Committed: Tue Aug 23 15:01:02 2016 -0700 ---------------------------------------------------------------------- .../apex/malhar/kafka/AbstractKafkaInputOperator.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/e44caa5a/kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaInputOperator.java ----------------------------------------------------------------------
