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 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
.TopicPartition Used to add topic/partition information to aKafkaListener
.