Spring 使用应用程序的批处理侦听器的 kafka 集成属性。yml/properties
Spring kafka integration properties for batch listener using application.yml/properties
我正在尝试在 spring 启动应用程序中使用 kafka 消费者批处理。我可以看到示例，其中我们有一个 kafka 配置 class，其中配置了 KafkaListenerContainerFactory 和
ConcurrentKafkaListenerContainerFactory.setBatchListener(true);
已启用。我只是想知道这是否可以在没有工厂 class 的情况下实现，即通过在 application.yml 中使用 spring kafka 集成属性。早些时候我定义了一个工厂，并通过 application.yml 将其替换为 spring kafa 集成属性，以获得简洁的代码。我试图了解后者是否有限制和使用配置 class 更可取，因为我无法通过 application.yml 使用 spring kafa 集成属性实现批处理。 https://docs.spring.io/spring-boot/docs/current/reference/html/appendix-application-properties.html 我参考了此文档以查看可用选项。
spring.kafka.listener.type=batch（与 single - 默认值相比）。
引导文档需要一些改进。
我正在尝试在 spring 启动应用程序中使用 kafka 消费者批处理。我可以看到示例，其中我们有一个 kafka 配置 class，其中配置了 KafkaListenerContainerFactory 和
ConcurrentKafkaListenerContainerFactory.setBatchListener(true);
已启用。我只是想知道这是否可以在没有工厂 class 的情况下实现，即通过在 application.yml 中使用 spring kafka 集成属性。早些时候我定义了一个工厂，并通过 application.yml 将其替换为 spring kafa 集成属性，以获得简洁的代码。我试图了解后者是否有限制和使用配置 class 更可取，因为我无法通过 application.yml 使用 spring kafa 集成属性实现批处理。 https://docs.spring.io/spring-boot/docs/current/reference/html/appendix-application-properties.html 我参考了此文档以查看可用选项。
spring.kafka.listener.type=batch（与 single - 默认值相比）。
引导文档需要一些改进。