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

Question

我试图在spring boot应用程序中使用kafka消费者批处理。我可以看到一些例子，其中我们有一个kafka配置类，其中，KafkaListenerContainerFactory被配置并

ConcurrentKafkaListenerContainerFactory.setBatchListener(true);

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

Answer 1

spring.kafka.listener.type=批处理（Vs.

引导留档需要一些改进。