Package org.springframework.kafka.config
@NonNullApi
package org.springframework.kafka.config
Package for kafka configuration
-
ClassDescriptionBase
KafkaListenerContainerFactory
for Spring's base container implementation.Base model for a Kafka listener endpoint.CompositeKafkaStreamsCustomizer
customizesKafkaStreams
by delegating to a list of providedKafkaStreamsCustomizer
.CompositeKafkaStreamsInfrastructureCustomizer
customizesKafkaStreams
by delegating to a list of providedKafkaStreamsInfrastructureCustomizer
.AKafkaListenerContainerFactory
implementation to build aConcurrentMessageListenerContainer
.ContainerCustomizer<K,V, C extends AbstractMessageListenerContainer<K, V>> Called by the container factory after the container is created and configured.ContainerPostProcessor<K,V, C extends AbstractMessageListenerContainer<K, V>> Called by the container factory after the container is created and configured.Configuration constants for internal sharing across subpackages.Factory forMessageListenerContainer
s.Model for a Kafka listener endpoint.Helper bean for registeringKafkaListenerEndpoint
with aKafkaListenerEndpointRegistry
.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.TheMethodKafkaListenerEndpoint
extension for several POJO methods based on theKafkaHandler
.AnAbstractFactoryBean
for theStreamsBuilder
instance and lifecycle control for the internalKafkaStreams
instance.Called whenever aKafkaStreams
is added or removed.A configurer forStreamsBuilderFactoryBean
.Builder for aNewTopic
.