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
相关产品推荐
相关产品推荐

