You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/01/19 05:50:00 UTC

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

Jingsong Lee created FLINK-25696:
------------------------------------

             Summary: 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, Table Store
            Reporter: Jingsong Lee
            Assignee: Jingsong Lee
             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)