Uses of Package
org.springframework.kafka.listener
Package
Description
Package for kafka configuration
Package for kafka listeners
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
Package for retryable topic handling.
Package for classes related to Kafka Streams.
-
ClassDescriptionThe base implementation for the
MessageListenerContainer
.Invoked by a listener container with remaining, unprocessed, records (including the failed record).Deprecated, for removal: This API element is subject to removal in a future version.An interceptor for batches of records.Replacement forErrorHandler
andBatchErrorHandler
and their sub-interfaces.Creates 1 or moreKafkaMessageListenerContainer
s based onconcurrency
.Contains runtime properties for a listener container.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.An error handler which is called when a@KafkaListener
method throws an exception.A registry for listener containers.Internal abstraction used by the framework representing a message listener container.An interceptor forConsumerRecord
invoked by the listener container before and after invoking the listener. -
ClassDescriptionBase class for
KafkaBackOffManagerFactory
implementations.The base implementation for theMessageListenerContainer
.Invoked by a listener container with remaining, unprocessed, records (including the failed record).Handler for the provided back off time, listener container and exception.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.An interceptor for batches of records.Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.Replacement forErrorHandler
andBatchErrorHandler
and their sub-interfaces.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.AConsumerRecordRecoverer
that supports getting a reference to theConsumer
.Objects that can publish consumer pause/resume events.Common consumer properties.ABiConsumer
extension for recovering consumer records.Listeners that implement this interface are provided with aConsumerSeekAware.ConsumerSeekCallback
which can be used to perform a seek operation.A callback that a listener can invoke to seek to a specific offset.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.Contains runtime properties for a listener container.The offset commit behavior enumeration.Offset commit behavior during assignment.Mode for exactly once semantics.Use this to provide a custom implementation to take complete control over exception header creation for the output record.Container class for the name of the headers that will be added to the produced record.Headers for data relative to the exception thrown.Headers for data relative to the original record.Header names for exception headers.Bits representing which headers to add.Header names for original record property headers.A component implementing this interface can provide the next delivery attempt.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.Supports exception classification.Subclass ofFailedRecordProcessor
that can process (and recover) a batch.Common super class for classes that deal with failing to consume a consumer record.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.Top level interface for listeners.Generic message listener container; adds parameters.Creates aKafkaBackOffManagerFactory
instance.Interface for backing off aMessageListenerContainer
until a given dueTimestamp, if such timestamp is in the future.Provides the state that will be used for backing off.A top level abstract class for classes that can be configured with aKafkaException.Level
.An error handler which is called when a@KafkaListener
method throws an exception.Single-threaded Message listener container using the JavaConsumer
supporting auto-partition assignment or user-configured assignment.Service for pausing and resuming ofMessageListenerContainer
.A registry for listener containers.The listener specificKafkaException
extension.Metadata associated to aKafkaListener
.Defines the listener type.Listener for handling individual incoming Kafka messages.Internal abstraction used by the framework representing a message listener container.Provider forOffsetAndMetadata
.An interceptor forConsumerRecord
invoked by the listener container before and after invoking the listener.Called to determine whether a record should be skipped.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofCommonErrorHandler
.A listener for retry activity.A general interface for managing thread-bound resources when aConsumer
is available. -
ClassDescriptionListener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.A
BiConsumer
extension for recovering consumer records.Listeners that implement this interface are provided with aConsumerSeekAware.ConsumerSeekCallback
which can be used to perform a seek operation.A callback that a listener can invoke to seek to a specific offset.Classes implementing this interface allow containers to determine the type of the ultimate listener.Top level interface for listeners.Exception thrown when the consumer should not yet consume the message due to backOff.Interface for backing off aMessageListenerContainer
until a given dueTimestamp, if such timestamp is in the future.An error handler which is called when a@KafkaListener
method throws an exception.Defines the listener type.Listener for handling individual incoming Kafka messages. -
ClassDescriptionListener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.Listeners that implement this interface are provided with a
ConsumerSeekAware.ConsumerSeekCallback
which can be used to perform a seek operation.Top level interface for listeners.Generic message listener container; adds parameters. -
ClassDescriptionReplacement for
ErrorHandler
andBatchErrorHandler
and their sub-interfaces.Creates 1 or moreKafkaMessageListenerContainer
s based onconcurrency
.AConsumerRecordRecoverer
that publishes a failed record to a dead-letter topic.An error handler that, for record listeners, seeks to the current offset for each topic in the remaining records.Supports exception classification.Creates aKafkaBackOffManagerFactory
instance.Interface for backing off aMessageListenerContainer
until a given dueTimestamp, if such timestamp is in the future.A top level abstract class for classes that can be configured with aKafkaException.Level
.A registry for listener containers. -
CommonErrorHandler
.