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 to support the use of MockConsumer and MockProducer.
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.A template for executing high-level operations. -
ClassDescriptionThe strategy to produce a
Consumer
instance.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.An admin that delegates to anAdminClient
to create topics defined in the application context.Provides a number of convenience methods wrappingAdminClient
.The basic Kafka operations contract returningCompletableFuture
s.A callback for executing arbitrary operations on theKafkaOperations
.A callback for executing arbitrary operations on theProducer
.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.The strategy for managing transactional producer suffixes. -
ClassDescriptionThe strategy to produce a
Consumer
instance.An admin that delegates to anAdminClient
to create topics defined in the application context.The basic Kafka operations contract returningCompletableFuture
s. -
-
ClassDescriptionThe strategy to produce a
Consumer
instance.The strategy to produce aProducer
instance(s). -
ClassDescriptionThe basic Kafka operations contract returning
CompletableFuture
s.A template for executing high-level operations.The strategy to produce aProducer
instance(s). -
-