org.springframework.kafka.annotation

Class KafkaBootstrapConfiguration

java.lang.Object

org.springframework.kafka.annotation.KafkaBootstrapConfiguration

@Configuration
public class KafkaBootstrapConfiguration
extends java.lang.Object

@Configuration class that registers a KafkaListenerAnnotationBeanPostProcessor bean capable of processing Spring's @KafkaListener annotation. Also register a default KafkaListenerEndpointRegistry.

This configuration class is automatically imported when using the @EnableKafka annotation. See EnableKafka Javadoc for complete usage.

Author:

Stephane Nicoll, Gary Russell

See Also:

KafkaListenerAnnotationBeanPostProcessor, KafkaListenerEndpointRegistry, EnableKafka

Constructor Summary

Constructors

Constructor and Description
KafkaBootstrapConfiguration()

Method Summary

Modifier and Type	Method and Description
KafkaListenerEndpointRegistry	defaultKafkaListenerEndpointRegistry()
KafkaListenerAnnotationBeanPostProcessor	kafkaListenerAnnotationProcessor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaBootstrapConfiguration

public KafkaBootstrapConfiguration()

Method Detail

kafkaListenerAnnotationProcessor

@Bean(name="org.springframework.kafka.config.internalKafkaListenerAnnotationProcessor")
 @Role(value=2)
public KafkaListenerAnnotationBeanPostProcessor kafkaListenerAnnotationProcessor()

defaultKafkaListenerEndpointRegistry

@Bean(name="org.springframework.kafka.config.internalKafkaListenerEndpointRegistry")
public KafkaListenerEndpointRegistry defaultKafkaListenerEndpointRegistry()