@NonNullApi

Package org.springframework.kafka.config

Package for kafka configuration

Interface Summary

Interface	Description
ContainerCustomizer<K,V,C extends AbstractMessageListenerContainer<K,V>>	Called by the container factory after the container is created and configured.
KafkaListenerContainerFactory<C extends MessageListenerContainer>	Factory for MessageListenerContainers.
KafkaListenerEndpoint	Model for a Kafka listener endpoint.
KafkaStreamsCustomizer	Callback interface that can be used to configure KafkaStreams directly.
KafkaStreamsInfrastructureCustomizer	A customizer for infrastructure components such as the StreamsBuilder and Topology.
StreamsBuilderFactoryBean.Listener	Called whenever a KafkaStreams is added or removed.
StreamsBuilderFactoryBeanConfigurer	A configurer for StreamsBuilderFactoryBean.
StreamsBuilderFactoryBeanCustomizer	Deprecated. in favor of StreamsBuilderFactoryBeanConfigurer due to a name clash with a similar class in Spring Boot.

Class Summary

Class	Description
AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V>	Base KafkaListenerContainerFactory for Spring's base container implementation.
AbstractKafkaListenerEndpoint<K,V>	Base model for a Kafka listener endpoint.
CompositeKafkaStreamsCustomizer	Composite KafkaStreamsCustomizer customizes KafkaStreams by delegating to a list of provided KafkaStreamsCustomizer.
CompositeKafkaStreamsInfrastructureCustomizer	Composite KafkaStreamsInfrastructureCustomizer customizes KafkaStreams by delegating to a list of provided KafkaStreamsInfrastructureCustomizer.
ConcurrentKafkaListenerContainerFactory<K,V>	A KafkaListenerContainerFactory implementation to build a ConcurrentMessageListenerContainer.
KafkaListenerConfigUtils	Configuration constants for internal sharing across subpackages.
KafkaListenerEndpointRegistrar	Helper bean for registering KafkaListenerEndpoint with a KafkaListenerEndpointRegistry.
KafkaListenerEndpointRegistry	Creates the necessary MessageListenerContainer instances for the registered endpoints.
KafkaStreamsConfiguration	Wrapper for StreamsBuilder properties.
MethodKafkaListenerEndpoint<K,V>	A KafkaListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
MultiMethodKafkaListenerEndpoint<K,V>	The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.
StreamsBuilderFactoryBean	An AbstractFactoryBean for the StreamsBuilder instance and lifecycle control for the internal KafkaStreams instance.
TopicBuilder	Builder for a NewTopic.