[ https://issues.apache.org/jira/browse/KAFKA-19547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ejaskhan resolved KAFKA-19547. ------------------------------ Resolution: Abandoned Created the issue here, https://issues.apache.org/jira/browse/FLINK-38226 > Kafka Sink Improvement: Add failOnError to Control Exception Behavior > --------------------------------------------------------------------- > > Key: KAFKA-19547 > URL: https://issues.apache.org/jira/browse/KAFKA-19547 > Project: Kafka > Issue Type: Bug > Reporter: Ejaskhan > Priority: Major > Labels: Kafka, flink-connector-kafka > Attachments: image-2025-07-25-00-56-15-542.png > > > Currently, even if the delivery guarantee is set to {*}NONE{*}, the Kafka > sink throws an exception, which results in job restarts. > !image-2025-07-25-00-56-15-542.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. -- This message was sent by Atlassian Jira (v8.20.10#820010)