Merge branch 'STORM-3046-1.x' of https://github.com/srdo/storm into STORM-3046-1.x-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d5ead668 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d5ead668 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d5ead668 Branch: refs/heads/1.x-branch Commit: d5ead66813937e4bb80bd7e0440a66eb987fc48f Parents: 4e1e626 e63f552 Author: Jungtaek Lim <kabh...@gmail.com> Authored: Fri Jul 13 10:31:07 2018 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Fri Jul 13 10:31:07 2018 +0900 ---------------------------------------------------------------------- .../spout/trident/KafkaTridentSpoutEmitter.java | 54 ++++++++++++-------- 1 file changed, 32 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/d5ead668/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitter.java ----------------------------------------------------------------------
