Package org.springframework.kafka.config
@NonNullApi
package org.springframework.kafka.config
Package for kafka configuration
-
ClassDescriptionBase
KafkaListenerContainerFactoryfor Spring's base container implementation.Base model for a Kafka listener endpoint.CompositeKafkaStreamsCustomizercustomizesKafkaStreamsby delegating to a list of providedKafkaStreamsCustomizer.CompositeKafkaStreamsInfrastructureCustomizercustomizesKafkaStreamsby delegating to a list of providedKafkaStreamsInfrastructureCustomizer.AKafkaListenerContainerFactoryimplementation to build aConcurrentMessageListenerContainer.ContainerCustomizer<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 forMessageListenerContainers.Model for a Kafka listener endpoint.Helper bean for registeringKafkaListenerEndpointwith aKafkaListenerEndpointRegistry.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.TheMethodKafkaListenerEndpointextension for several POJO methods based on theKafkaHandler.AnAbstractFactoryBeanfor theStreamsBuilderinstance and lifecycle control for the internalKafkaStreamsinstance.Called whenever aKafkaStreamsis added or removed.A configurer forStreamsBuilderFactoryBean.Builder for aNewTopic.