GH-970: Add getGroupId() to containers

Resolves https://github.com/spring-projects/spring-kafka/issues/970

- allow retrieval of the `group.id`, even if not set on the container properties
- also add `getAllListenerContainers` to the `RLERegistry` as a convenience
- also add `getListenerId` to return the id or bean name of the container
This commit is contained in:
Gary Russell
2019-02-22 11:15:12 -05:00
committed by Artem Bilan
parent 5a98a510d3
commit 45ddac7fea
7 changed files with 85 additions and 7 deletions

View File

@@ -1320,6 +1320,11 @@ private KafkaListenerEndpointRegistry registry;
----
====
The registry only maintains the life cycle of containers it manages; containers declared as beans are not managed by the registry and can be obtained from the application context.
A collection of managed containers can be obtained by calling the registry's `getListenerContainers()` method.
Version 2.2.5 added a convenience method `getAllListenerContainers()`, which returns a collection of all containers, including those managed by the registry and those declared as beans.
The collection returned will include any prototype beans that have been initialized, but it will not initialize any lazy bean declarations.
[[kafka-validation]]
===== `@KafkaListener` `@Payload` Validation