You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/06/10 15:04:31 UTC
[03/10] storm git commit: Merge branch 'cap-retry' of
https://github.com/abhishekagarwal87/storm into 1.x-branch
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 <pt...@gmail.com>
Authored: Fri Jun 10 10:25:32 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
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
----------------------------------------------------------------------