[
https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058999#comment-16058999
]
ASF GitHub Bot commented on FLINK-6923:
---------------------------------------
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4149
@zhenzhongxu if I understood you correctly, instead of this solution, would
it then make sense for your case to make the Kafka offset committing happen
only when the checkpoint is completed, not when it is triggered, i.e. commit in
the `notifyCheckpointComplete` callback of `CheckpointListener`?
> Kafka connector needs to expose information about in-flight record in
> AbstractFetcher base class
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-6923
> URL: https://issues.apache.org/jira/browse/FLINK-6923
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Zhenzhong Xu
> Assignee: Zhenzhong Xu
> Priority: Minor
>
> We have a use case where we have our custom Fetcher implementation that
> extends AbstractFetcher base class. We need to periodically get current in
> flight (in processing) records' partition and offset information.
> This can be easily exposed in AbstractFetcher class.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
