Merge branch 'STORM-2544' of https://github.com/askprasanna/storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/89ad4215 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/89ad4215 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/89ad4215 Branch: refs/heads/master Commit: 89ad42153b93e0eccebd25cd462157975ea53f2a Parents: 110c405 d250ae0 Author: Stig Rohde Døssing <s...@apache.org> Authored: Tue Jul 18 10:46:05 2017 +0200 Committer: Stig Rohde Døssing <s...@apache.org> Committed: Tue Jul 18 10:46:05 2017 +0200 ---------------------------------------------------------------------- .../apache/storm/kafka/spout/KafkaSpout.java | 5 +- .../kafka/spout/KafkaSpoutRetryLimitTest.java | 126 +++++++++++++++++++ 2 files changed, 130 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/89ad4215/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java ----------------------------------------------------------------------
