Package org.springframework.kafka.listener
@NonNullApi
package org.springframework.kafka.listener
Package for kafka listeners
-
ClassDescriptionManages the
ConsumerSeekAware.ConsumerSeekCallback
s for the listener.Base class forKafkaBackOffManagerFactory
implementations.The base implementation for theMessageListenerContainer
.Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.Invoked by a listener container with remaining, unprocessed, records (including the failed record).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, 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.Deprecated.BatchInterceptor<K,V> An interceptor for batches of records.An exception thrown by user code to inform the framework which record in a batch has failed.BatchMessageListener<K,V> Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.ACommonErrorHandler
that stops the container when an error occurs.An error handler that delegates to different error handlers, depending on the exception type.Replacement forErrorHandler
andBatchErrorHandler
and their sub-interfaces.TheCommonErrorHandler
implementation for logging exceptions.ACommonErrorHandler
that delegates to differentCommonErrorHandler
s for record and batch listeners.ABatchInterceptor
that delegates to one or moreBatchInterceptor
s in order.ARecordInterceptor
that delegates to one or moreRecordInterceptor
s in order.Creates 1 or moreKafkaMessageListenerContainer
s based onconcurrency
.Deprecated.in favor ofCommonErrorHandler
.Deprecated.in favor ofCommonErrorHandler
.An error handler that has access to the consumer.Listener for handling individual incoming Kafka messages.A rebalance listener that provides access to the consumer object.Deprecated.- useRecordInterceptor
.AConsumerRecordRecoverer
that supports getting a reference to theConsumer
.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.in favor ofCommonErrorHandler
.Deprecated.in favor ofCommonErrorHandler
.A group of listener containers.Sequence the starting of container groups when all containers in the previous group are idle.Contains runtime properties for a listener container.The offset commit behavior enumeration.Offset commit behavior during assignment.Mode for exactly once semantics.AConsumerRecordRecoverer
that publishes a failed record to a dead-letter topic.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.Provides a convenient API for creatingDeadLetterPublishingRecoverer.HeaderNames
.Header names for exception headers.Bits representing which headers to add.Header names for original record property headers.Default implementation ofAfterRollbackProcessor
.An error handler that, for record listeners, seeks to the current offset for each topic in the remaining records.Classes implementing this interface allow containers to determine the type of the ultimate listener.A component implementing this interface can provide the next delivery attempt.Deprecated.in favor ofCommonErrorHandler
.Utilities for error handling.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.in favor ofCommonErrorHandler
.Top level interface for listeners.Generic message listener container; adds parameters.Exception thrown when the consumer should not yet consume the message due to backOff.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.Adjusts the consumption timing of the given consumer to try to have it consume the next message at a given time until due.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.A registry for listener containers.The listener specificKafkaException
extension.Deprecated.in favor ofCommonErrorHandler
.Defines the listener type.Listener utilities.Logs commit results at DEBUG level for success and ERROR for failures.MessageListener<K,V> Listener for handling individual incoming Kafka messages.Internal abstraction used by the framework representing a message listener container.A manager that backs off consumption for a given topic if the timestamp provided is not due.Creates aKafkaConsumerBackoffManager
instance with or without aKafkaConsumerTimingAdjuster
.RecordInterceptor<K,V> An interceptor forConsumerRecord
invoked by the listener container before and after invoking the listener.Called to determine whether a record should be skipped.Deprecated.in favor ofCommonErrorHandler
.A listener for retry activity.Seek utilities.A general interface for managing thread-bound resources when aConsumer
is available.AKafkaException
that records the timestamp of when it was thrown.Adjusts timing by creating a thread that will wakeup the consumer from polling, considering that, if consumption is paused, it will check for consumption resuming in increments of 'pollTimeout'.
CommonErrorHandler
.