Uses of Package
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.
-
ClassDescriptionHelper bean for registering
KafkaListenerEndpoint
with aKafkaListenerEndpointRegistry
.Creates the necessaryMessageListenerContainer
instances for the registered endpoints.Wrapper forStreamsBuilder
properties.AKafkaListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint.AnAbstractFactoryBean
for theStreamsBuilder
instance and lifecycle control for the internalKafkaStreams
instance. -
ClassDescriptionBase
KafkaListenerContainerFactory
for 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 forMessageListenerContainer
s.Model for a Kafka listener endpoint.Creates the necessaryMessageListenerContainer
instances for the registered endpoints.Wrapper forStreamsBuilder
properties.Callback interface that can be used to configureKafkaStreams
directly.A customizer for infrastructure components such as theStreamsBuilder
andTopology
.AKafkaListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint.AnAbstractFactoryBean
for theStreamsBuilder
instance and lifecycle control for the internalKafkaStreams
instance.Called whenever aKafkaStreams
is added or removed.Builder for aNewTopic
. -
ClassDescriptionA
KafkaListenerContainerFactory
implementation to build aConcurrentMessageListenerContainer
.Factory forMessageListenerContainer
s.Model for a Kafka listener endpoint.Helper bean for registeringKafkaListenerEndpoint
with aKafkaListenerEndpointRegistry
.AKafkaListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint. -
ClassDescriptionAn
AbstractFactoryBean
for theStreamsBuilder
instance and lifecycle control for the internalKafkaStreams
instance.Called whenever aKafkaStreams
is added or removed.