Interface KafkaListenerConfigurer
public interface KafkaListenerConfigurer
Optional interface to be implemented by Spring managed bean willing
to customize how Kafka listener endpoints are configured. Typically
used to define the default
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.
- Author:
- Stephane Nicoll
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Callback allowing aKafkaListenerEndpointRegistry
and specificKafkaListenerEndpoint
instances to be registered against the givenKafkaListenerEndpointRegistrar
.
-
Method Details
-
configureKafkaListeners
Callback allowing aKafkaListenerEndpointRegistry
and specificKafkaListenerEndpoint
instances to be registered against the givenKafkaListenerEndpointRegistrar
. The defaultKafkaListenerContainerFactory
can also be customized.- Parameters:
registrar
- the registrar to be configured
-