Jingsong Lee created FLINK-25184:
------------------------------------
Summary: Introduce setDeliveryCallback to KafkaWriter
Key: FLINK-25184
URL: https://issues.apache.org/jira/browse/FLINK-25184
Project: Flink
Issue Type: Sub-task
Components: Connectors / Kafka
Reporter: Jingsong Lee
Fix For: 1.15.0
The method can be package level visibility.
Inside the managed table, we rely on this callback to know the offset of the
written message and use this offset to do full and incremental alignment.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)