Merge branch 'cap-retry' of https://github.com/abhishekagarwal87/storm into 1.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2d0fb215 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2d0fb215 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2d0fb215 Branch: refs/heads/1.x-branch Commit: 2d0fb215bb101d81d6dfd2092705dd00d51ad4a4 Parents: 244b166 5c706af Author: P. Taylor Goetz <[email protected]> Authored: Fri Jun 10 10:25:32 2016 -0400 Committer: P. Taylor Goetz <[email protected]> Committed: Fri Jun 10 10:25:32 2016 -0400 ---------------------------------------------------------------------- external/storm-kafka/README.md | 55 ++++++++++- .../ExponentialBackoffMsgRetryManager.java | 39 +++++--- .../storm/kafka/FailedMsgRetryManager.java | 60 ++++++++++-- .../apache/storm/kafka/PartitionManager.java | 33 +++++-- .../jvm/org/apache/storm/kafka/SpoutConfig.java | 8 +- .../ExponentialBackoffMsgRetryManagerTest.java | 99 +++++++++++++------- 6 files changed, 229 insertions(+), 65 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2d0fb215/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java ----------------------------------------------------------------------
