GitHub user zhenzhongxu opened a pull request:
https://github.com/apache/flink/pull/4149
[FLINK-6923] [Kafka Connector] Expose in-processing/in-flight record â¦
This PR exposes current in-processing record partition and offset
information per Kafka consumer instance. This allows custom offset management
and/or periodical metric reporting etc.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhenzhongxu/flink master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4149.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 #4149
----
commit e6b4c6070661b8275af55280f6364f6666a2d5f2
Author: Zhenzhong Xu <z...@netflix.com>
Date: 2017-06-20T20:47:50Z
[FLINK-6923] [Kafka Connector] Expose in-processing/in-flight record
partition and offset in AbstractFetcher base class
----
---
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.
---
