You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2026/01/19 13:17:00 UTC

[jira] [Created] (FLINK-38947) Notify Task thread via mailbox only once about kafka send error

Roman Khachatryan created FLINK-38947:
-----------------------------------------

             Summary: Notify Task thread via mailbox only once about kafka send error
                 Key: FLINK-38947
                 URL: https://issues.apache.org/jira/browse/FLINK-38947
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
    Affects Versions: 2.2.0
            Reporter: Roman Khachatryan
            Assignee: Roman Khachatryan
             Fix For: 2.3.0


KafkaWriter supplies a complection [callback|https://github.com/apache/flink-connector-kafka/blob/dc4efea959842463da95359a29c34b7a07211032/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java#L307] when handing records to KafkaProducer.

Upon request completion, KafkaProducer executes the callback once per record. There might be more than one (usually, a lot) of records in a single request.

In case of error, this results in many identical mails enqueued into Task mailbox.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)