Merge pull request #1 from rick-kilgore/retryDelay exponential backoff for failed messages moving repo to HBOCodeLabs
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1c748a7f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1c748a7f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1c748a7f Branch: refs/heads/master Commit: 1c748a7fde11ebc7d209c16ad2b30bf19a316395 Parents: 5aae768 6138e94 Author: Rick Kilgore <[email protected]> Authored: Sat Sep 6 00:08:12 2014 -0700 Committer: Rick Kilgore <[email protected]> Committed: Sat Sep 6 00:08:12 2014 -0700 ---------------------------------------------------------------------- .../src/jvm/storm/kafka/PartitionManager.java | 66 ++++++++++++++++++-- .../src/jvm/storm/kafka/SpoutConfig.java | 3 + 2 files changed, 65 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
