Springboot Kafka：kafka_batchConvertedHeaders自定义Header反序列化异常

问题本质 #

自定义Header显示[B@xxxxxx是因为Kafka Header的原始值是字节数组，批量监听器默认不会自动将自定义Header的字节数组转换为字符串——Confluent自带的常规Header有内置反序列化逻辑，但自定义Header没有，直接输出了字节数组的对象标识。

解决方法 #

方法1：手动转换字节数组为字符串 #

在批量监听器的处理逻辑里，遍历kafka_batchConvertedHeaders，将每个Header的字节数组值转成指定编码的字符串：

// 假设headers是获取到的批量Header集合
for (Header header : headers) {
    String headerName = header.key();
    byte[] headerValueBytes = header.value();
    String headerValue = new String(headerValueBytes, StandardCharsets.UTF_8);
    // 处理转换后的Header值
}

注意要和生产者发送Header时使用的编码保持一致（通常用UTF-8）。

方法2：配置全局Header反序列化器 #

通过配置DefaultKafkaHeaderMapper让框架自动处理自定义Header的反序列化，以Spring Boot为例：

@Bean
public BatchMessagingMessageConverter batchMessageConverter() {
    DefaultKafkaHeaderMapper headerMapper = new DefaultKafkaHeaderMapper();
    // 开启字符串类型Header的自动映射（入站）
    headerMapper.setMapStringsIn(true);
    BatchMessagingMessageConverter converter = new BatchMessagingMessageConverter();
    converter.setHeaderMapper(headerMapper);
    return converter;
}

配置后，框架会自动将字节数组类型的自定义Header转换为字符串，无需手动处理。

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