不二糖 2020-09-05 13:34 采纳率: 0%
浏览 1242
已结题

kafka突然发送失败,用的spring-kafka,今天提交2条是发送成功,之后又提交了一批5万的就发送失败了,之前都是正常运行的也提交过大批量的数据都是成功发送的,是因为有配置不正确吗?下面是回调里面的错误信息

org.springframework.kafka.core.KafkaProducerException: Failed to send;
nested exception is org.apache.kafka.common.errors.TimeoutException:

Expiring 7 record(s) for msg-send-topic-1: 30091 ms has passed since batch creation plus linger time

org.springframework.kafka.core.KafkaTemplate.lambda$buildCallback$0(KafkaTemplate.java:431)

org.apache.kafka.clients.producer.KafkaProducer$InterceptorCallback.onCompletion(KafkaProducer.java:1235)

org.apache.kafka.clients.producer.internals.ProducerBatch.completeFutureAndFireCallbacks(ProducerBatch.java:204)

org.apache.kafka.clients.producer.internals.ProducerBatch.done(ProducerBatch.java:187)

org.apache.kafka.clients.producer.internals.Sender.failBatch(Sender.java:635)

Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 7 record(s) for msg-send-topic-1: 30091 ms has passed since batch creation plus linger time

  • 写回答

2条回答 默认 最新

  • dabocaiqq 2020-09-05 13:47
    关注
    评论

报告相同问题?

问题事件

  • 请采纳用户回复 10月12日

悬赏问题

  • ¥50 永磁型步进电机PID算法
  • ¥15 sqlite 附加(attach database)加密数据库时,返回26是什么原因呢?
  • ¥88 找成都本地经验丰富懂小程序开发的技术大咖
  • ¥15 如何处理复杂数据表格的除法运算
  • ¥15 如何用stc8h1k08的片子做485数据透传的功能?(关键词-串口)
  • ¥15 有兄弟姐妹会用word插图功能制作类似citespace的图片吗?
  • ¥200 uniapp长期运行卡死问题解决
  • ¥15 latex怎么处理论文引理引用参考文献
  • ¥15 请教:如何用postman调用本地虚拟机区块链接上的合约?
  • ¥15 为什么使用javacv转封装rtsp为rtmp时出现如下问题:[h264 @ 000000004faf7500]no frame?