Spring-kafka KafkaListener 在运行时自动启动行为

Question

我正在使用 spring-Kafka 作为消费者应用程序运行一个 spring 应用程序。在 Kafka 监听器中，我们使用 SpEL 表达式设置了自动启动。我们在运行时更改此值以使此表达式为 false。当我们更改属性时，KafkaListener 将停止消费更多消息。

问题：这是停止轮询进一步记录的正确方法还是我们应该使用 kafkaListenerEndpointRegistry 并停止服务？这两者有什么区别？

另一个问题是，如果我有另一个应用程序使用同一消费者组，所有分区都会重新分配给该应用程序吗？

Answer 1

autoStartup仅考虑一次（在应用程序上下文初始化期间）。如果为 true，则容器将启动，如果为 false，则不会启动。

初始化后在运行时更改属性不会停止容器。

您必须通过容器注册表使用停止/启动来在上下文启动并运行后停止/启动容器）。

如果同一个组中有多个实例，则分区将分布在各个实例上；一个分区只能被同一组中的一个消费者消费。