GitHub user srdo opened a pull request:
https://github.com/apache/storm/pull/2357
STORM-2666 (1.1.x)
This is https://github.com/apache/storm/pull/2356 plus one commit to fix
conflicts.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srdo/storm STORM-2666-1.1.x
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2357.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 #2357
----
commit 4971543052e84161431887c5e471e6f4be917dff
Author: Stig Rohde Døssing <[email protected]>
Date: 2017-08-12T14:56:45Z
STORM-2666: Fix storm-kafka-client spout sometimes emitting messages that
were already committed. Expand tests, add some runtime validation, minor
refactoring to increase code readability. Ensure OffsetManager commits as many
offsets as possible when an offset void (deleted offsets) occurs, rather than
just up to the gap.
commit 7d290affa44265c49665331a83271c0c33051c93
Author: Stig Rohde Døssing <[email protected]>
Date: 2017-10-04T18:46:46Z
Backport to Java 7 and revert changes to RetryService API
commit d8da7ca08e6979df81544eb2add1adc7358bad30
Author: Stig Rohde Døssing <[email protected]>
Date: 2017-10-04T19:19:16Z
Backport to 1.1.x
----
---
