Package org.springframework.kafka.annotation

Package for kafka annotations

Interface Summary

Interface	Description
KafkaListenerAnnotationBeanPostProcessor.AnnotationEnhancer	Post processes each set of annotation attributes.
KafkaListenerConfigurer	Optional interface to be implemented by Spring managed bean willing to customize how Kafka listener endpoints are configured.

Class Summary

Class	Description
KafkaBootstrapConfiguration	An ImportBeanDefinitionRegistrar class that registers a KafkaListenerAnnotationBeanPostProcessor bean capable of processing Spring's @KafkaListener annotation.
KafkaListenerAnnotationBeanPostProcessor<K,V>	Bean post-processor that registers methods annotated with KafkaListener to be invoked by a Kafka message listener container created under the covers by a KafkaListenerContainerFactory according to the parameters of the annotation.
KafkaListenerConfigurationSelector	A DeferredImportSelector implementation with the lowest order to import a KafkaBootstrapConfiguration as late as possible.
KafkaNullAwarePayloadArgumentResolver	PayloadMethodArgumentResolver that can properly decode KafkaNull payloads, returning null.
KafkaStreamsDefaultConfiguration	@Configuration class that registers a StreamsBuilderFactoryBean if StreamsConfig with the name KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME is present in the application context.
RetryableTopicAnnotationProcessor	Processes the provided RetryableTopic annotation returning an RetryTopicConfiguration.
RetryTopicConfigurationProvider	Attempts to provide an instance of RetryTopicConfiguration by either creating one from a RetryableTopic annotation, or from the bean container if no annotation is available.

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 a AbstractListenerContainerFactory.
EnableKafkaRetryTopic	Enables the non-blocking topic-based delayed retries feature.
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 with KafkaListener.
KafkaListener	Annotation that marks a method to be the target of a Kafka message listener on the specified topics.
KafkaListeners	Container annotation that aggregates several KafkaListener annotations.
PartitionOffset	Used to add partition/initial offset information to a KafkaListener.
RetryableTopic	Annotation to create the retry and dlt topics for a KafkaListener annotated listener.
TopicPartition	Used to add topic/partition information to a KafkaListener.