Package org.springframework.kafka.annotation

package org.springframework.kafka.annotation

Package for kafka annotations

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka

Class	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.
KafkaBootstrapConfiguration	An ImportBeanDefinitionRegistrar class that registers a KafkaListenerAnnotationBeanPostProcessor bean capable of processing Spring's @KafkaListener annotation.
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.
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.
KafkaListenerAnnotationBeanPostProcessor.AnnotationEnhancer	Post processes each set of annotation attributes.
KafkaListenerConfigurationSelector	A DeferredImportSelector implementation with the lowest order to import a KafkaBootstrapConfiguration as late as possible.
KafkaListenerConfigurer	Optional interface to be implemented by Spring managed bean willing to customize how Kafka listener endpoints are configured.
KafkaListeners	Container annotation that aggregates several KafkaListener annotations.
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.
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.
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.
TopicPartition	Used to add topic/partition information to a KafkaListener.