Uses of Package
org.springframework.kafka.config
Packages that use org.springframework.kafka.config
Package
Description
Package for kafka annotations
Package for kafka configuration
Package for retryable topic handling.
Package for classes related to Kafka Streams.
-
Classes in org.springframework.kafka.config used by org.springframework.kafka.annotationClassDescriptionHelper bean for registering
KafkaListenerEndpointwith aKafkaListenerEndpointRegistry.Creates the necessaryMessageListenerContainerinstances for the registered endpoints.Wrapper forStreamsBuilderproperties.AKafkaListenerEndpointproviding the method to invoke to process an incoming message for this endpoint.AnAbstractFactoryBeanfor theStreamsBuilderinstance and lifecycle control for the internalKafkaStreamsinstance. -
Classes in org.springframework.kafka.config used by org.springframework.kafka.configClassDescriptionBase
KafkaListenerContainerFactoryfor Spring's base container implementation.Base model for a Kafka listener endpoint.Called by the container factory after the container is created and configured.Called by the container factory after the container is created and configured.Factory forMessageListenerContainers.Model for a Kafka listener endpoint.Creates the necessaryMessageListenerContainerinstances for the registered endpoints.Wrapper forStreamsBuilderproperties.Callback interface that can be used to configureKafkaStreamsdirectly.A customizer for infrastructure components such as theStreamsBuilderandTopology.AKafkaListenerEndpointproviding the method to invoke to process an incoming message for this endpoint.AnAbstractFactoryBeanfor theStreamsBuilderinstance and lifecycle control for the internalKafkaStreamsinstance.Called whenever aKafkaStreamsis added or removed.Builder for aNewTopic. -
Classes in org.springframework.kafka.config used by org.springframework.kafka.retrytopicClassDescriptionA
KafkaListenerContainerFactoryimplementation to build aConcurrentMessageListenerContainer.Factory forMessageListenerContainers.Model for a Kafka listener endpoint.Helper bean for registeringKafkaListenerEndpointwith aKafkaListenerEndpointRegistry.AKafkaListenerEndpointproviding the method to invoke to process an incoming message for this endpoint. -
Classes in org.springframework.kafka.config used by org.springframework.kafka.streamsClassDescriptionAn
AbstractFactoryBeanfor theStreamsBuilderinstance and lifecycle control for the internalKafkaStreamsinstance.Called whenever aKafkaStreamsis added or removed.