FlinkFlink 写入 kafka 报错 Failed to send data to Kafka: Expiring 4 record(s) for 20001 ms has passed(代码

Posted 2021-08-01 九师兄

1.场景1

1.1 概述

有一个flink 写入kafka的程序报错，如下

Failed to send data to Kafka: Expiring 4 record(s) for BM-DEV-STATUS-18-0:120001 ms has passed since batch creation

flink中写入kafka 抛这种错误一般是什么原因，导致job重启

1.2 百度

转载：原文链接：https://blog.csdn.net/u010002184/article/details/117708404

消息在producer端发送时，是先保存在中间缓存中，组成批，如果批等了超过默认时间限制30s后，还没发送出去就会报这个异常，同时该批的消息都会从发送队列中删除掉（丢失）！

https://stackoverflow.com/questions/46750420/kafka-producer-error-expiring-10-records-for-topicxxxxxx-6686-ms-has-passed