'Inject all Kafka Consumers created by a ConcurrentMessageListenerContainer in Spring Boot?

We are using the ConcurrentMessageListenerContainer to create our Kafka Consumers.

With the ConcurrentMessageListenerContainer#concurrency property it is possible to create multiple consumers.

Is it possible in a Spring Boot application to inject all Consumers created by the ConcurrentMessageListenerContainer? Or is it possible to obtain them somehow after an ApplicationEvent?

javaspringspring-bootapache-kafkaspring-kafka


Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source

Related Questions