public interface KafkaListenerConfigurer
KafkaListenerContainerFactory to use or for registering Kafka endpoints
in a programmatic fashion as opposed to the declarative
approach of using the @KafkaListener annotation.
See @EnableKafka for detailed usage examples.
EnableKafka,
KafkaListenerEndpointRegistrar| Modifier and Type | Method and Description |
|---|---|
void |
configureKafkaListeners(KafkaListenerEndpointRegistrar registrar)
Callback allowing a
KafkaListenerEndpointRegistry and specific KafkaListenerEndpoint instances to be registered against the given
KafkaListenerEndpointRegistrar. |
void configureKafkaListeners(KafkaListenerEndpointRegistrar registrar)
KafkaListenerEndpointRegistry and specific KafkaListenerEndpoint instances to be registered against the given
KafkaListenerEndpointRegistrar. The default
KafkaListenerContainerFactory
can also be customized.registrar - the registrar to be configured