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)
