Merge branch '1.x-branch_STORM-2409_KSBTSupport' of https://github.com/hmcl/storm-apache into 2409-1.x
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d32f44c7 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d32f44c7 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d32f44c7 Branch: refs/heads/1.x-branch Commit: d32f44c74065597969c24f20ea1730d07c758fa3 Parents: 620d2be 8670f60 Author: Satish Duggana <[email protected]> Authored: Tue Mar 21 11:37:44 2017 +0530 Committer: Satish Duggana <[email protected]> Committed: Tue Mar 21 11:37:44 2017 +0530 ---------------------------------------------------------------------- .../apache/storm/kafka/spout/KafkaSpout.java | 124 +++++++++++-------- .../storm/kafka/spout/KafkaSpoutConfig.java | 33 +++-- .../storm/kafka/spout/KafkaSpoutMessageId.java | 21 +++- .../storm/kafka/spout/RecordTranslator.java | 9 +- .../storm/kafka/spout/KafkaSpoutConfigTest.java | 19 ++- 5 files changed, 140 insertions(+), 66 deletions(-) ----------------------------------------------------------------------
