[GitHub] storm pull request #2356: STORM-2666 (1.x)

[asfgit]

Github user asfgit closed the pull request at:

https://github.com/apache/storm/pull/2356


---

[GitHub] storm pull request #2356: STORM-2666 (1.x)

[srdo]

GitHub user srdo opened a pull request:

https://github.com/apache/storm/pull/2356

STORM-2666 (1.x)

Please see https://github.com/apache/storm/pull/2277. I've put all the 
changes for this branch in their own commit for easy review.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/srdo/storm STORM-2666-clean-1.x

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/storm/pull/2356.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 #2356


commit 9b95f3da608760b334bb8a9a272e64e0fb9fb3ac
Author: Stig Rohde Døssing 
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 54fdcbc03be47c95b8e9d177f525e031afb5e946
Author: Stig Rohde Døssing 
Date:   2017-10-04T18:46:46Z

Backport to Java 7 and revert changes to RetryService API




---