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 to support the use of MockConsumer and MockProducer.
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 aConsumerinstance(s).A template for executing high-level operations. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.coreClassDescriptionThe strategy to produce a
Consumerinstance(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.An admin that delegates to anAdminClientto create topics defined in the application context.Provides a number of convenience methods wrappingAdminClient.The basic Kafka operations contract returningCompletableFutures.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 aProducerinstance(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.dynamicClassDescriptionWrapper for a collection of
NewTopicto facilitate declaring multiple topics as a single bean. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.jdocs.requestreplyClassDescriptionWrapper for a collection of
NewTopicto 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
Consumerinstance(s).A template for executing high-level operations.The strategy to produce aProducerinstance(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
AdminClientto create topics defined in the application context.Wrapper for a collection ofNewTopicto facilitate declaring multiple topics as a single bean. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.listenerClassDescriptionThe strategy to produce a
Consumerinstance(s).An admin that delegates to anAdminClientto create topics defined in the application context.The basic Kafka operations contract returningCompletableFutures. -
Classes in org.springframework.kafka.core used by org.springframework.kafka.listener.adapter
-
Classes in org.springframework.kafka.core used by org.springframework.kafka.mockClassDescriptionThe strategy to produce a
Consumerinstance(s).The strategy to produce aProducerinstance(s). -
Classes in org.springframework.kafka.core used by org.springframework.kafka.requestreplyClassDescriptionThe basic Kafka operations contract returning
CompletableFutures.A template for executing high-level operations.The strategy to produce aProducerinstance(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