Class KafkaListenerAnnotationBeanPostProcessor<K,V>

Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
Aware, BeanPostProcessor, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Ordered

public class KafkaListenerAnnotationBeanPostProcessor<K,V> extends Object implements BeanPostProcessor, Ordered, ApplicationContextAware, InitializingBean, SmartInitializingSingleton
Bean post-processor that registers methods annotated with KafkaListener to be invoked by a Kafka message listener container created under the covers by a KafkaListenerContainerFactory according to the parameters of the annotation.

Annotated methods can use flexible arguments as defined by KafkaListener.

This post-processor is automatically registered by Spring's EnableKafka annotation.

Auto-detect any KafkaListenerConfigurer instances in the container, allowing for customization of the registry to be used, the default container factory or for fine-grained control over endpoints registration. See EnableKafka Javadoc for complete usage details.

Stephane Nicoll, Juergen Hoeller, Gary Russell, Artem Bilan, Dariusz Szablinski, Venil Noronha, Dimitri Penner, Filip Halemba, Tomaz Fernandes, Wang Zhiyang
See Also: