Skip to content
GitLab

flink - kafka_sink delivery_guarantee option

Merged Ottomata requested to merge kafka_sink_delivery_guarantee into main

This will allow us to set a Kafka DeliveryGuarantee from config. The default delivery_guarantee for KafkaSink is NONE.

https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#fault-tolerance

Bug: T325303