GitHub user srdo opened a pull request:
https://github.com/apache/storm/pull/2484
STORM-2869 1.x
https://github.com/apache/storm/pull/2481 for 1.x
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srdo/storm STORM-2869-1.x
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2484.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 #2484
----
commit 8129368771341d33fb7d36754c29351a86bc49a0
Author: Stig Rohde Døssing <srdo@...>
Date: 2017-12-26T19:55:30Z
STORM-2869: Only discard outdated records when adjusting KafkaConsumer
position during commit
commit bcec474ae27a9524f69f5d68a88e9ab1e0eb4bf9
Author: Stig Rohde Døssing <srdo@...>
Date: 2017-12-28T09:32:45Z
Backport
----
---
