Package org.springframework.kafka.core

@NullMarked package org.springframework.kafka.core

Package for kafka core components

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka

Class	Description
ABSwitchCluster	A Supplier for bootstrap servers that can toggle between 2 lists of servers.
CleanupConfig	Specifies time of KafkaStreams.cleanUp() execution.
ConsumerFactory<K,V>	The strategy to produce a Consumer instance.
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.
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.
DefaultShareConsumerFactory<K,V>	The ShareConsumerFactory implementation to produce new ShareConsumer instances for provided Map configs and optional Deserializers on each DefaultShareConsumerFactory.createShareConsumer(String, String) invocation.
DefaultTransactionIdSuffixStrategy	The TransactionIdSuffixStrategy implementation for managing transactional producer suffixes.
KafkaAdmin	An admin that delegates to an Admin 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.
KafkaAdminOperations	Provides a number of convenience methods wrapping AdminClient.
KafkaMetricsSupport<C>	An abstract class to manage KafkaClientMetrics.
KafkaOperations<K,V>	The basic Kafka operations contract returning CompletableFutures.
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.
KafkaProducerException	Exceptions when producing.
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.
NoProducerAvailableException	Exception when no producer is available.
ProducerFactory<K,V>	The strategy to produce a Producer instance(s).
ProducerFactory.Listener<K,V>	Called whenever a producer is added or removed.
ProducerFactoryUtils	Helper class for managing a Spring based Kafka DefaultKafkaProducerFactory in particular for obtaining transactional Kafka resources for a given ProducerFactory.
ProducerPostProcessor<K,V>	Called by producer factories to perform post processing on newly created producers.
RoutingKafkaTemplate	A KafkaTemplate that routes messages based on the topic name.
ShareConsumerFactory<K,V>	The strategy to produce a ShareConsumer instance for Kafka queue support.
ShareConsumerFactory.Listener<K,V>	Listener for share consumer lifecycle events.
TransactionIdSuffixStrategy	The strategy for managing transactional producer suffixes.