GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/1016
add some enhancements to MockConsumer
The MockConsumer class should support adding records concurrently.
This allow to implement more complex test scenarios in which records are
added concurrently with the records are polled.
In addition, I've implemented the rebalance callback in simple manner.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhussonnois/kafka trunk
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1016.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 #1016
----
commit 04de0d66124eb0669568c9c292a50decdae4826f
Author: Florian Hussonnois <[email protected]>
Date: 2016-03-05T09:59:50Z
Fix MockConsumer must support concurrent adding records
commit c180d914e249764339192db6ce0a2a2e88325b12
Author: Florian Hussonnois <[email protected]>
Date: 2016-03-05T10:04:24Z
Add rebalance callbacks MockConsumer
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
