使用 application.yml/properties 的批处理侦听器的 Spring kafka 集成属性

Question

我正在尝试在 Spring Boot 应用程序中使用 kafka 消费者批处理。我可以看到示例，我们有一个 kafka 配置类，其中配置了 KafkaListenerContainerFactory 和

ConcurrentKafkaListenerContainerFactory.setBatchListener(true);

已启用。我只是想知道这是否可以在没有工厂类的情况下实现，即通过在 application.yml 中使用 spring kafka 集成属性。早些时候我已经定义了一个工厂，并通过 application.yml 将其替换为 spring kafa 集成属性，以获得简洁的代码。我试图了解后者是否有限制，并且使用配置类更可取，因为我无法通过 application.yml 使用 spring kafa 集成属性来实现批处理。 https://docs.spring.io/spring-boot/docs/current/reference/html/appendix-application-properties.html 我参考了这个文档来查看可用的选项。

Answer 1

spring.kafka.listener.type=batch（对比single - 默认）。

Boot 文档可能需要一些改进。