GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/3811
KAFKA-5839: Upgrade Guide doc changes for KIP-130
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhussonnois/kafka KAFKA-5839
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/2612
KAFKA-4819: Expose states for active tasks to public API
Simple implementation of the feature :
[KAFKA-4819](https://issues.apache.org/jira/browse/KAFKA-4819)
KAFKA-4819
This PR
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/2604
KAFKA-4794: Add access to OffsetStorageReader from SourceConnector
This a first attempt to implement Add access to OffsetStorageReader from
Source Connector.
I am not sure if I did it right
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/1581
KAFKA-3922: add constructor to AbstractStream class
https://issues.apache.org/jira/browse/KAFKA-3922
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/1415
KAFKA-3737: Change log level for error during produce request
Minor change for https://issues.apache.org/jira/browse/KAFKA-3737
You can merge this pull request into a Git repository by running
GitHub user fhussonnois opened a pull request:
https://github.com/apache/kafka/pull/1179
KAFKA-3496 - add policies for client reconnect attempts
In addition, this PR fixes some log level as describe in this issue :
https://issues.apache.org/jira/browse/KAFKA-2998
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
