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 <[email protected]>
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 <[email protected]>
Date: 2017-02-06T18:19:44Z
Address review comments
commit e85ad2dbf7ef58cbd3e8de8533f7dec7de0b5f5e
Author: Stig Rohde Døssing <[email protected]>
Date: 2017-02-16T13:47:58Z
Address more review comments, fix merge from master
commit dd3a2c7d086898260fe633bcc8fed033336ad566
Author: Stig Rohde Døssing <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
