Package org.springframework.kafka.core
@NonNullApi
package org.springframework.kafka.core
Package for kafka core components
-
ClassDescriptionA
Supplier
for bootstrap servers that can toggle between 2 lists of servers.Specifies time ofKafkaStreams.cleanUp()
execution.ConsumerFactory<K,V> The strategy to produce aConsumer
instance(s).Called whenever a consumer is added or removed.Called by consumer factories to perform post processing on newly created consumers.TheConsumerFactory
implementation to produce newConsumer
instances for providedMap
configs
and optionalDeserializer
s on eachConsumerFactory.createConsumer()
invocation.A wrapper class for the delegate.An admin that delegates to anAdminClient
to create topics defined in the application context.Wrapper for a collection ofNewTopic
to facilitate declaring multiple topics as a single bean.Provides a number of convenience methods wrappingAdminClient
.KafkaOperations<K,V> The basic Kafka operations contract returningCompletableFuture
s.A callback for executing arbitrary operations on theKafkaOperations
.A callback for executing arbitrary operations on theProducer
.KafkaOperations2<K,V> Deprecated, for removal: This API element is subject to removal in a future version.Exceptions when producing.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.A consumer factory listener that managesKafkaClientMetrics
.A producer factory listener that managesKafkaClientMetrics
.ProducerFactory<K,V> The strategy to produce aProducer
instance(s).Called whenever a producer is added or removed.Helper class for managing a Spring based KafkaDefaultKafkaProducerFactory
in particular for obtaining transactional Kafka resources for a given ProducerFactory.Called by producer factories to perform post processing on newly created producers.AKafkaTemplate
that routes messages based on the topic name.
KafkaOperations
.