在 Spring Boot 中注入由 ConcurrentMessageListenerContainer 创建的所有 Kafka 消费者？
Inject all Kafka Consumers created by a ConcurrentMessageListenerContainer in Spring Boot?
我们正在使用 ConcurrentMessageListenerContainer to create our Kafka Consumers。
使用 ConcurrentMessageListenerContainer#concurrency 属性 可以创建多个消费者。
是否可以在 Spring 引导应用程序中注入所有 Consumers created by the ConcurrentMessageListenerContainer? Or is it possible to obtain them somehow after an ApplicationEvent？
为什么需要访问底层 Consumer 对象？它们由容器管理。
消费者可作为消息侦听器中的参数使用，并包含在已发布的事件中，但不建议直接使用 Consumer API，因为这种用法可能与容器的预期冲突。
使用被动API是可以的，比如获取订阅主题的结束偏移量
我们正在使用 ConcurrentMessageListenerContainer to create our Kafka Consumers。
使用 ConcurrentMessageListenerContainer#concurrency 属性 可以创建多个消费者。
是否可以在 Spring 引导应用程序中注入所有 Consumers created by the ConcurrentMessageListenerContainer? Or is it possible to obtain them somehow after an ApplicationEvent？
为什么需要访问底层 Consumer 对象？它们由容器管理。
消费者可作为消息侦听器中的参数使用，并包含在已发布的事件中，但不建议直接使用 Consumer API，因为这种用法可能与容器的预期冲突。
使用被动API是可以的，比如获取订阅主题的结束偏移量