如何在Spring Kafka Consumer中跳过损坏的（不可序列化的）消息？

如何在Spring Kafka Consumer中跳过损坏的（不可序列化的）消息？

您需要

ErrorHandlingDeserializer

：https : //docs.spring.io/spring-
kafka/docs/2.2.0.RELEASE/reference/html/_reference.html#error-handling-
deserializer

如果无法升级到该

2.2

版本，请考虑实施自己的版本并返回

null

无法正确反序列化的那些记录。

源代码在这里：[https](https://github.com/spring-projects/spring-

kafka/blob/master/spring-

kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java)

//github.com/spring-projects/spring-kafka/blob/master/spring-
kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java