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 AnImportBeanDefinitionRegistrarclass that registers aKafkaListenerAnnotationBeanPostProcessorbean capable of processing Spring's @KafkaListenerannotation.KafkaListenerAnnotationBeanPostProcessor<K,V> Bean post-processor that registers methods annotated withKafkaListenerto be invoked by a Kafka message listener container created under the covers by aKafkaListenerContainerFactoryaccording to the parameters of the annotation.KafkaListenerConfigurationSelector ADeferredImportSelectorimplementation with the lowest order to import aKafkaBootstrapConfigurationas late as possible.KafkaStreamsDefaultConfiguration @Configurationclass that registers aStreamsBuilderFactoryBeanifStreamsConfigwith the nameKafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAMEis 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 severalKafkaListenerannotations.PartitionOffset Used to add partition/initial offset information to aKafkaListener.TopicPartition Used to add topic/partition information to aKafkaListener.