Package org.springframework.kafka.core

@NonNullApi package org.springframework.kafka.core

Package for kafka core components

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka
org.springframework.kafka.core.reactive	Reactive component for consumer and producer.

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.
DefaultTransactionIdSuffixStrategy	The TransactionIdSuffixStrategy implementation for managing transactional producer suffixes.
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.
KafkaAdminOperations	Provides a number of convenience methods wrapping AdminClient.
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.
TransactionIdSuffixStrategy	The strategy for managing transactional producer suffixes.