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 defined the defaultKafkaListenerContainerFactory
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:
EnableKafka
,KafkaListenerEndpointRegistrar
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
configureKafkaListeners(KafkaListenerEndpointRegistrar registrar)
Callback allowing aKafkaListenerEndpointRegistry
and specificKafkaListenerEndpoint
instances to be registered against the givenKafkaListenerEndpointRegistrar
.
-
-
-
Method Detail
-
configureKafkaListeners
void configureKafkaListeners(KafkaListenerEndpointRegistrar registrar)
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
-
-