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)