@NonNullApi

Package org.springframework.kafka.core

Package for kafka core components

Interface Summary

Interface	Description
ConsumerFactory<K,V>	The strategy to produce a Consumer instance(s).
ConsumerFactory.Listener<K,V>	Called whenever a consumer is added or removed.
ConsumerPostProcessor<K,V>	Called by consumer factories to perform post processing on newly created consumers.
KafkaAdminOperations	Provides a number of convenience methods wrapping AdminClient.
KafkaFailureCallback<K,V>	Deprecated. as of 2.9.1, in favor of CompletableFuture.whenComplete(BiConsumer)
KafkaOperations<K,V>	The basic Kafka operations contract returning ListenableFutures.
KafkaOperations.OperationsCallback<K,V,T>	A callback for executing arbitrary operations on the KafkaOperations.
KafkaOperations.ProducerCallback<K,V,T>	A callback for executing arbitrary operations on the Producer.
KafkaOperations2<K,V>	The basic Kafka operations contract returning CompletableFutures.
KafkaSendCallback<K,V>	Deprecated. as of 2.9.1, in favor of CompletableFuture.whenComplete(BiConsumer)
ProducerFactory<K,V>	The strategy to produce a Producer instance(s).
ProducerFactory.Listener<K,V>	Called whenever a producer is added or removed.
ProducerPostProcessor<K,V>	Called by producer factories to perform post processing on newly created producers.

Class Summary

Class	Description
ABSwitchCluster	A Supplier for bootstrap servers that can toggle between 2 lists of servers.
CleanupConfig	Specifies time of KafkaStreams.cleanUp() execution.
DefaultKafkaConsumerFactory<K,V>	The ConsumerFactory implementation to produce new Consumer instances for provided Map configs and optional Deserializers on each ConsumerFactory.createConsumer() invocation.
DefaultKafkaProducerFactory<K,V>	The ProducerFactory implementation for a singleton shared Producer instance.
DefaultKafkaProducerFactory.CloseSafeProducer<K,V>	A wrapper class for the delegate.
KafkaAdmin	An admin that delegates to an AdminClient to create topics defined in the application context.
KafkaAdmin.NewTopics	Wrapper for a collection of NewTopic to facilitate declaring multiple topics as a single bean.
KafkaResourceFactory	Base class for consumer/producer/admin creators.
KafkaResourceHolder<K,V>	Kafka resource holder, wrapping a Kafka producer.
KafkaTemplate<K,V>	A template for executing high-level operations.
MicrometerConsumerListener<K,V>	A consumer factory listener that manages KafkaClientMetrics.
MicrometerProducerListener<K,V>	A producer factory listener that manages KafkaClientMetrics.
ProducerFactoryUtils	Helper class for managing a Spring based Kafka DefaultKafkaProducerFactory in particular for obtaining transactional Kafka resources for a given ProducerFactory.
RoutingKafkaTemplate	A KafkaTemplate that routes messages based on the topic name.

Exception Summary

Exception	Description
KafkaProducerException	Exceptions when producing.