Uses of Package
org.springframework.kafka.core
Package
Description
Package for kafka configuration
Package for kafka core components
Package for kafka listeners
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
Package for retryable topic handling.
Provides classes related to transactions.
-
ClassDescriptionSpecifies time of
KafkaStreams.cleanUp()
execution.The strategy to produce aConsumer
instance(s).A template for executing high-level operations. -
ClassDescriptionThe strategy to produce a
Consumer
instance(s).Called whenever a consumer is added or removed.Called by consumer factories to perform post processing on newly created consumers.A wrapper class for the delegate.Provides a number of convenience methods wrappingAdminClient
.An enhancedFailureCallback
for reportingKafkaProducerException
s.The basic Kafka operations contract returningListenableFuture
s.A callback for executing arbitrary operations on theKafkaOperations
.A callback for executing arbitrary operations on theProducer
.Exceptions when producing.Base class for consumer/producer/admin creators.Kafka resource holder, wrapping a Kafka producer.A template for executing high-level operations.The strategy to produce aProducer
instance(s).Called whenever a producer is added or removed.Called by producer factories to perform post processing on newly created producers. -
ClassDescriptionWrapper for a collection of
NewTopic
to facilitate declaring multiple topics as a single bean. -
ClassDescriptionThe strategy to produce a
Consumer
instance(s).A template for executing high-level operations.The strategy to produce aProducer
instance(s). -
-
ClassDescriptionAn admin that delegates to an
AdminClient
to create topics defined in the application context.Wrapper for a collection ofNewTopic
to facilitate declaring multiple topics as a single bean. -
ClassDescriptionThe strategy to produce a
Consumer
instance(s).The basic Kafka operations contract returningListenableFuture
s. -
-
ClassDescriptionThe basic Kafka operations contract returning
ListenableFuture
s.A template for executing high-level operations.The strategy to produce aProducer
instance(s). -
-