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

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日

悬赏问题

  • ¥15 目详情-五一模拟赛详情页
  • ¥15 有了解d3和topogram.js库的吗?有偿请教
  • ¥100 任意维数的K均值聚类
  • ¥15 stamps做sbas-insar,时序沉降图怎么画
  • ¥15 买了个传感器,根据商家发的代码和步骤使用但是代码报错了不会改,有没有人可以看看
  • ¥15 关于#Java#的问题,如何解决?
  • ¥15 加热介质是液体,换热器壳侧导热系数和总的导热系数怎么算
  • ¥100 嵌入式系统基于PIC16F882和热敏电阻的数字温度计
  • ¥15 cmd cl 0x000007b
  • ¥20 BAPI_PR_CHANGE how to add account assignment information for service line