Class KafkaListenerEndpointRegistry

java.lang.Object
org.springframework.kafka.config.KafkaListenerEndpointRegistry
All Implemented Interfaces:
EventListener, Aware, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, Lifecycle, Phased, SmartLifecycle, ListenerContainerRegistry

Creates the necessary MessageListenerContainer instances for the registered endpoints. Also manages the lifecycle of the listener containers, in particular within the lifecycle of the application context.

Contrary to MessageListenerContainers created manually, listener containers managed by registry are not beans in the application context and are not candidates for autowiring. Use getListenerContainers() if you need to access this registry's listener containers for management purposes. If you need to access to a specific message listener container, use getListenerContainer(String) with the id of the endpoint.

Author:
Stephane Nicoll, Juergen Hoeller, Artem Bilan, Gary Russell, Asi Bross, Wang Zhiyang, Joo Hyuk Kim
See Also: