集成测试中为新增KafkaListener配置自定义值反序列化器的问题

在spring-kafka 2.5.8版本中，完全可以不自定义ListenerContainerFactory，直接通过@KafkaListener的properties参数指定专属的反序列化器，你之前的配置未生效是因为属性名格式和键值对分隔符使用错误。

正确配置方式 #

将properties参数中的属性名改为Kafka原生消费者配置的value.deserializer（使用点分隔，而非Spring Boot配置里的短横线），同时键值对用等号=分隔，而非冒号:：

@KafkaListener(topics = "...", properties = "value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer")
public void receiveKafkaRecords(final ConsumerRecord<String, byte[]> record) {
    // 业务逻辑
}

如果需要同时配置多个属性，可以使用数组形式：

@KafkaListener(topics = "...", properties = {
    "value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer",
    "auto.offset.reset=earliest"
})
public void receiveKafkaRecords(final ConsumerRecord<String, byte[]> record) {
    // 业务逻辑
}

原配置失效原因 #

你之前使用的value-deserializer:xxx格式存在两个问题：

1. 属性名错误：@KafkaListener的properties参数需要使用Kafka原生消费者的配置键（如value.deserializer），而非Spring Boot配置文件中的短横线命名（value-deserializer）；
2. 分隔符错误：键值对必须用等号=分隔，冒号:无法被正确解析为配置项的键值关系。

这两个错误导致你的自定义反序列化器配置未被加载，监听器依然使用了全局配置的StringDeserializer，因此出现String转byte[]的类型转换异常。

内容的提问来源于stack exchange，提问作者ItIsJustMe