You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

spring-kafka 3.1.3反序列化异常致重试循环,是否为回归问题?

问题:Spring-Kafka 3.1.3反序列化异常处理引发无限循环及序列化错误
  • 将Spring Boot从3.2.3升级到3.2.4,同步升级Spring-Kafka从3.1.2到3.1.3后,部分测试失败
  • 问题仅在处理触发反序列化异常的事件时出现:自定义FailedDeserializationFunction会被调用,但错误事件被传播到配置的重试主题,进而引发无限循环
  • 降级回Spring Boot 3.2.3/Spring-Kafka 3.1.2后问题可解决

使用Spring-Kafka 3.1.3运行测试时出现如下报错:

INFO 143594 --- [kafka-dlt] [yListener-0-C-1] c.e.k.FailedDeserializationFunction      : Failed to deserialize event - returning default
 ERROR 143594 --- [kafka-dlt] [yListener-0-C-1] o.s.k.l.DeadLetterPublishingRecoverer    : Dead-letter publication to test-topic-kafka-dlt-retry-0 failed for: test-topic-0@1
    
    org.apache.kafka.common.errors.SerializationException: Can't convert value of class [B to class org.apache.kafka.common.serialization.IntegerSerializer specified in value.serializer
        at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:1003) ~[kafka-clients-3.6.1.jar:na]
        at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:947) ~[kafka-clients-3.6.1.jar:na]
        at org.springframework.kafka.core.DefaultKafkaProducerFactory$CloseSafeProducer.send(DefaultKafkaProducerFactory.java:1050) ~[spring-kafka-3.1.3.jar:3.1.3]

请问这是我的操作有误,还是该版本存在回归问题?

内容的提问来源于stack exchange,提问作者Lorenzo Von Matterhorn

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.27 17:56:05