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. I prefer to take your feedbacks before writing some tests. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhussonnois/kafka KAFKA-4794 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2604.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 #2604 ---- commit e2bb682afd052cf1c83c68933c1165b584a0acc9 Author: Florian Hussonnois <florian.hussonn...@gmail.com> Date: 2017-02-27T22:35:33Z KAFKA-4794: Add access to OffsetStorageReader from SourceConnector ---- --- 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---