[jira] [Updated] (FLINK-25696) Introduce MetadataPublisher interface to SinkWriter

["Jingsong Lee (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jingsong Lee updated FLINK-25696:
---------------------------------
    Component/s: Connectors / Kafka

> Introduce MetadataPublisher interface to SinkWriter
> ---------------------------------------------------
>
>                 Key: FLINK-25696
>                 URL: https://issues.apache.org/jira/browse/FLINK-25696
>             Project: Flink
>          Issue Type: New Feature
>          Components: API / DataStream, Connectors / Kafka, Table Store
>            Reporter: Jingsong Lee
>            Assignee: Jingsong Lee
>            Priority: Major
>             Fix For: 1.15.0
>
>
> In Table Store, we want to get the offsets of kafka writer, only the offset returned by the callback inside the KafkaWriter is accurate, so we need this callback mechanism.
> This ticket wants to add a interface MetadataPublisher:
> {code:java}
> public interface MetadataPublisher<MetaT> {
>     void subscribe(Consumer<MetaT> consumer);
> } {code}
> SinkWriter can implement this interface, so that table store can subscribe metadata from SinkWriter.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)