[
https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089387#comment-16089387
]
ASF GitHub Bot commented on FLINK-6923:
---------------------------------------
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4149
+1 agree with @aljoscha here.
The main problem with this change is that there is no usages of it in other
parts of the codebase, and can very easily be removed "accidentally" in the
future.
> 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)
