[
https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-25696:
-
Parent: FLINK-25152
Issue Type: Sub-task (was: New Feature)
> Introduce metadataConsume
[
https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-25696:
-
Description:
In Table Store, we want to get the offsets of kafka writer, only the offset
return
[
https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-25696:
-
Summary: Introduce metadataConsumer to InitContext in Sink (was: Introduce
MetadataPublisher in
