Package org.springframework.kafka.annotation
Package for kafka annotations
-
Interface Summary Interface Description KafkaListenerConfigurer Optional interface to be implemented by Spring managed bean willing to customize how Kafka listener endpoints are configured. -
Class Summary Class Description KafkaBootstrapConfiguration AnImportBeanDefinitionRegistrar
class that registers aKafkaListenerAnnotationBeanPostProcessor
bean capable of processing Spring's @KafkaListener
annotation.KafkaListenerAnnotationBeanPostProcessor<K,V> Bean post-processor that registers methods annotated withKafkaListener
to be invoked by a Kafka message listener container created under the covers by aKafkaListenerContainerFactory
according to the parameters of the annotation.KafkaListenerConfigurationSelector ADeferredImportSelector
implementation with the lowest order to import aKafkaBootstrapConfiguration
as late as possible.KafkaStreamsDefaultConfiguration @Configuration
class that registers aStreamsBuilderFactoryBean
ifStreamsConfig
with the nameKafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME
is present in the application context. -
Annotation Types Summary Annotation Type Description DltHandler Annotation to determine the method the should process the DLT topic message.EnableKafka Enable Kafka listener annotated endpoints that are created under the covers by aAbstractListenerContainerFactory
.EnableKafkaStreams Enable default Kafka Streams components.KafkaHandler Annotation that marks a method to be the target of a Kafka message listener within a class that is annotated withKafkaListener
.KafkaListener Annotation that marks a method to be the target of a Kafka message listener on the specified topics.KafkaListeners Container annotation that aggregates severalKafkaListener
annotations.PartitionOffset Used to add partition/initial offset information to aKafkaListener
.RetryableTopic Annotation to create the retry and dlt topics for aKafkaListener
annotated listener.TopicPartition Used to add topic/partition information to aKafkaListener
.