org.springframework.kafka.annotation

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 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:

EnableKafka, KafkaListenerEndpointRegistrar

Method Summary

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.

Method Detail

configureKafkaListeners

void configureKafkaListeners(KafkaListenerEndpointRegistrar registrar)

Callback allowing a KafkaListenerEndpointRegistry and specific KafkaListenerEndpoint instances to be registered against the given KafkaListenerEndpointRegistrar. The default KafkaListenerContainerFactory can also be customized.

Parameters:

registrar - the registrar to be configured