[
https://issues.apache.org/jira/browse/FLINK-38226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ejaskhan updated FLINK-38226:
-----------------------------
Description:
Currently, even if the delivery guarantee is set to {*}NONE{*}, the Kafka sink
throws an exception, which results in job restarts.
!image-2025-08-27-17-09-29-768.png!
*Proposal:* Introduce a new configuration parameter, {{{}failOnError{}}}, in
{{KafkaSinkBuilder}} to suppress throwing the error and log it instead. With
this change, exceptions from the Kafka cluster will no longer result in job
restarts when the delivery guarantee is NONE and failOnError is false.
was:
Currently, even if the delivery guarantee is set to {*}NONE{*}, the Kafka sink
throws an exception, which results in job restarts.
!image-2025-08-12-09-48-40-505.png!
*Proposal:* Introduce a new configuration parameter, {{{}failOnError{}}}, in
{{KafkaSinkBuilder}} to suppress throwing the error and log it instead. With
this change, exceptions from the Kafka cluster will no longer result in job
restarts.
> Kafka Sink Improvement: Add failOnError to Control Exception Behavior
> ---------------------------------------------------------------------
>
> Key: FLINK-38226
> URL: https://issues.apache.org/jira/browse/FLINK-38226
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: Ejaskhan
> Priority: Major
> Labels: kafka
> Attachments: image-2025-08-12-09-48-40-505.png,
> image-2025-08-27-17-09-29-768.png
>
>
> Currently, even if the delivery guarantee is set to {*}NONE{*}, the Kafka
> sink throws an exception, which results in job restarts.
> !image-2025-08-27-17-09-29-768.png!
> *Proposal:* Introduce a new configuration parameter, {{{}failOnError{}}}, in
> {{KafkaSinkBuilder}} to suppress throwing the error and log it instead. With
> this change, exceptions from the Kafka cluster will no longer result in job
> restarts when the delivery guarantee is NONE and failOnError is false.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
