You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sa...@apache.org on 2017/03/21 06:47:53 UTC
[2/3] storm git commit: Merge branch
'1.x-branch_STORM-2409_KSBTSupport' of https://github.com/hmcl/storm-apache
into 2409-1.x
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 <sd...@hortonworks.com>
Authored: Tue Mar 21 11:37:44 2017 +0530
Committer: Satish Duggana <sd...@hortonworks.com>
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(-)
----------------------------------------------------------------------