GitHub user srdo opened a pull request: https://github.com/apache/storm/pull/2004
STORM-2413: Make new Kafka spout respect tuple retry limits Sorry about mixed diff, but https://github.com/apache/storm/pull/1924 had some changes I needed. Hopefully that one gets merged soon so the diff here is nicer. Only change from the other branch is https://github.com/srdo/storm/commit/86c39a349cdb053e1949ed1739feef0f6b2bcaf7 https://issues.apache.org/jira/browse/STORM-2413 You can merge this pull request into a Git repository by running: $ git pull https://github.com/srdo/storm STORM-2413 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/storm/pull/2004.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2004 ---- commit 801c26347cb68d7bfd3595bfffc83ab9915488d2 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-02-05T18:46:49Z STORM-2343: Fix new kafka spout stopping processing if more than maxUncommittedOffsets tuples fail at once commit 91b69ba19a4e9480f4a4c1a92f87cbbdd10cd2f2 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-02-06T18:19:44Z Address review comments commit e85ad2dbf7ef58cbd3e8de8533f7dec7de0b5f5e Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-02-16T13:47:58Z Address more review comments, fix merge from master commit dd3a2c7d086898260fe633bcc8fed033336ad566 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-03-02T18:49:48Z Pause partitions with no retriable messages when polling for retriable tuples while over the maxUncommittedOffsets limit commit 1617fe80c31f3f65ef6e07e8c8bffd8c2147dd5f Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-03-07T21:00:52Z Fix indentation, ensure consumer resume is called if consumer pause was called, add some comments and extra assertions to a few tests commit 8d10f82918ff6499dd47ba80b9d88ed9e28cf623 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-03-12T22:31:36Z Merge branch 'master' of https://github.com/apache/storm into STORM-2343 commit 2cc1015bcac6b29fffd35da72ef96f6d8915a4f9 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-03-13T17:25:31Z Merge branch 'master' of https://github.com/apache/storm into STORM-2343 commit 86c39a349cdb053e1949ed1739feef0f6b2bcaf7 Author: Stig Rohde Døssing <s...@it-minds.dk> Date: 2017-03-14T21:12:50Z STORM-2413: Make new Kafka spout respect tuple retry limit ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---