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)