Package org.springframework.kafka.config

@NullMarked package org.springframework.kafka.config

Package for kafka configuration

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka

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.
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.
KafkaListenerConfigUtils	Configuration constants for internal sharing across subpackages.
KafkaListenerContainerFactory<C extends MessageListenerContainer>	Factory for MessageListenerContainers.
KafkaListenerEndpoint	Model for a Kafka listener endpoint.
KafkaListenerEndpointRegistrar	Helper bean for registering KafkaListenerEndpoint with a KafkaListenerEndpointRegistry.
KafkaListenerEndpointRegistry	Creates the necessary MessageListenerContainer instances for the registered endpoints.
KafkaStreamsConfiguration	Wrapper for StreamsBuilder properties.
KafkaStreamsCustomizer	Callback interface that can be used to configure KafkaStreams directly.
KafkaStreamsInfrastructureCustomizer	A customizer for infrastructure components such as the StreamsBuilder and Topology.
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.
ShareKafkaListenerContainerFactory<K,V>	A KafkaListenerContainerFactory implementation to create ShareKafkaMessageListenerContainer instances for Kafka's share consumer model.
StreamsBuilderFactoryBean	An AbstractFactoryBean for the StreamsBuilder instance and lifecycle control for the internal KafkaStreams instance.
StreamsBuilderFactoryBean.Listener	Called whenever a KafkaStreams is added or removed.
StreamsBuilderFactoryBeanConfigurer	A configurer for StreamsBuilderFactoryBean.
TopicBuilder	Builder for a NewTopic.