[GitHub] storm pull request #2537: STORM-2914: Implement ProcessingGuarantee.NONE in ...

[srdo]

GitHub user srdo opened a pull request:

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

    STORM-2914: Implement ProcessingGuarantee.NONE in the spout instead o…

    …f using enable.auto.commit
    
    https://issues.apache.org/jira/browse/STORM-2914
    
    This change makes the spout commit offsets asynchronously when it is using 
ProcessingGuarantee.NONE. This behavior is very similar to how the consumer 
behaves when enable.auto.commit is true, but we need to do it manually due to 
https://issues.apache.org/jira/browse/STORM-2913. A nice side effect is that 
the commit timer setting in KafkaSpoutConfig now affects NONE as well as 
AT_LEAST_ONCE.

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

    $ git pull https://github.com/srdo/storm STORM-2914

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

    https://github.com/apache/storm/pull/2537.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 #2537
    
----
commit 3e09a1d718f8d40424e7ac5d574efe7a74706cf8
Author: Stig Rohde Døssing <srdo@...>
Date:   2018-01-27T18:22:07Z

    STORM-2914: Implement ProcessingGuarantee.NONE in the spout instead of 
using enable.auto.commit

----


---