如何复用KafkaListenerContainerFactory适配批量与非批量监听器及自定义转换器

针对你在Spring Kafka 2.8.9中遇到的复用工厂同时支持批量/非批量监听器并适配自定义MessageConverter的问题，有更稳定且不依赖内部API的解决方案：

推荐实现方式 #

直接将自定义MessageConverter包装到BatchMessagingMessageConverter中，并设置为工厂的全局消息转换器。BatchMessagingMessageConverter本身实现了MessageConverter和BatchMessageConverter接口，Spring Kafka会根据监听器的批量模式自动适配转换逻辑：

@Bean
public KafkaListenerContainerFactory<?> sharedKafkaListenerContainerFactory(ConsumerFactory<Object, Object> consumerFactory) {
    ConcurrentKafkaListenerContainerFactory<Object, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);

    // 实例化自定义MessageConverter
    CustomMessageConverter customMessageConverter = new CustomMessageConverter();

    // 用BatchMessagingMessageConverter包装自定义转换器，同时支持批量/非批量场景
    BatchMessagingMessageConverter batchCompatibleConverter = new BatchMessagingMessageConverter();
    batchCompatibleConverter.setRecordMessageConverter(customMessageConverter);

    // 设置工厂的消息转换器
    factory.setMessageConverter(batchCompatibleConverter);

    // 允许通过@KafkaListener的batch属性覆盖默认模式
    factory.setBatchListener(false);

    return factory;
}

方案优势 #

1. 无需依赖内部类：避免了你当前临时方案中依赖FilteringBatchMessageListenerAdapter、BatchMessagingMessageListenerAdapter等Spring Kafka内部实现类的问题，版本兼容性更强。
2. 自动适配模式：BatchMessagingMessageConverter会根据监听器是否为批量模式（由@KafkaListener(batch=true/false)指定）自动选择转换逻辑：
   • 非批量监听器：委托给自定义的recordMessageConverter处理单条消息
   • 批量监听器：执行批量消息转换逻辑
3. 避免误用风险：所有@KafkaListener注解只需通过batch属性切换模式，无需手动指定不同工厂，从根源上解决了开发者误用工厂导致的功能异常问题。

针对你的临时方案的说明 #

你当前的临时方案虽然能生效，但依赖Spring Kafka内部的监听器适配器层级结构，一旦后续版本调整内部类设计（比如适配器的继承关系、委托获取方式变化），代码就会失效。上述推荐方案基于Spring Kafka的公开API设计，稳定性更高。

内容的提问来源于stack exchange，提问作者D. Schmidt