Uses of Package
org.springframework.kafka.core
Packages that use 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.
-
Classes in org.springframework.kafka.core used by org.springframework.kafka.configClassDescriptionSpecifies time of
KafkaStreams.cleanUp()
execution.The strategy to produce aConsumer
instance(s).A template for executing high-level operations. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.coreClassDescriptionThe 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. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.jdocs.requestreplyClassDescriptionWrapper for a collection of
NewTopic
to facilitate declaring multiple topics as a single bean. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.jdocs.started.nobootClassDescriptionThe strategy to produce a
Consumer
instance(s).A template for executing high-level operations.The strategy to produce aProducer
instance(s). -
Classes in org.springframework.kafka.core used by org.springframework.kafka.jdocs.started.producer
-
Classes in org.springframework.kafka.core used by org.springframework.kafka.jdocs.topicsClassDescriptionAn 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. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.listenerClassDescriptionThe strategy to produce a
Consumer
instance(s).The basic Kafka operations contract returningListenableFuture
s. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.listener.adapter
-
Classes in org.springframework.kafka.core used by org.springframework.kafka.requestreplyClassDescriptionThe basic Kafka operations contract returning
ListenableFuture
s.A template for executing high-level operations.The strategy to produce aProducer
instance(s). -
Classes in org.springframework.kafka.core used by org.springframework.kafka.retrytopic
-
Classes in org.springframework.kafka.core used by org.springframework.kafka.transaction