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(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.
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.
KafkaAdminOperations	Provides a number of convenience methods wrapping AdminClient.
KafkaFailureCallback<K,V>	An enhanced FailureCallback for reporting KafkaProducerExceptions.
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.
KafkaProducerException	Exceptions when producing.
KafkaResourceFactory	Base class for consumer/producer/admin creators.
KafkaResourceHolder<K,V>	Kafka resource holder, wrapping a Kafka producer.
KafkaSendCallback<K,V>	An enhanced ListenableFutureCallback for reporting KafkaProducerExceptions.
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.
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.