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)
