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)

Reply via email to