[
https://issues.apache.org/jira/browse/FLINK-38947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38947:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Major
> Labels: pull-request-available
> 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)
