Merge branch 'STORM-KafkaRetry' of https://github.com/bijanfahimi/storm into STORM-2694-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/08d9d5a8 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/08d9d5a8 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/08d9d5a8 Branch: refs/heads/master Commit: 08d9d5a875ede000097a6a857db80541f76c0c58 Parents: d06bb38 6fef40b Author: Stig Rohde Døssing <s...@apache.org> Authored: Tue Aug 29 21:29:38 2017 +0200 Committer: Stig Rohde Døssing <s...@apache.org> Committed: Tue Aug 29 21:29:38 2017 +0200 ---------------------------------------------------------------------- .../kafka/spout/EmptyKafkaTupleListener.java | 53 +++++++++++++ .../apache/storm/kafka/spout/KafkaSpout.java | 15 +++- .../storm/kafka/spout/KafkaSpoutConfig.java | 26 +++++- .../storm/kafka/spout/KafkaTupleListener.java | 83 ++++++++++++++++++++ 4 files changed, 174 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
