GitHub user srdo opened a pull request:

    STORM-2974: Add transactional non-opaque spout to storm-kafka-client
    The changes outside the Trident package are because I'd like us to start 
 for testing instead of our own mockito mocks. In order to do that we have to 
refer to the Consumer interface instead of KafkaConsumer. The replacement is a 
breaking change in a few places. I'm not expecting this to go on 1.x, and 
backward compatibility was already broken in, so I haven't done any work to 
provide a smooth transition.
    I've tried to follow the transactional spout in storm-kafka to implement 
this as much as possible.
    There are a couple of followup tasks for this that I'll try to get done 
later, namely and

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

    $ git pull STORM-2974

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

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2590
commit b0294fef3696a8fa3a70e79ce5f54f79d1b86ef0
Author: Stig Rohde Døssing <srdo@...>
Date:   2018-03-09T19:57:53Z

    STORM-2974: Add transactional spout to storm-kafka-client



Reply via email to