Uses of Package
org.springframework.kafka.listener
Packages that use 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.
-
Classes in org.springframework.kafka.listener used by org.springframework.kafka.configClassDescriptionThe base implementation for the
MessageListenerContainer.Invoked by a listener container with remaining, unprocessed, records (including the failed record).Deprecated.An interceptor for batches of records.Replacement forErrorHandlerandBatchErrorHandlerand their sub-interfaces.Creates 1 or moreKafkaMessageListenerContainers based onconcurrency.Contains runtime properties for a listener container.Deprecated.in favor ofCommonErrorHandler.An error handler which is called when a@KafkaListenermethod throws an exception.A registry for listener containers.Internal abstraction used by the framework representing a message listener container.An interceptor forConsumerRecordinvoked by the listener container before and after invoking the listener. -
Classes in org.springframework.kafka.listener used by org.springframework.kafka.listenerClassDescriptionBase class for
KafkaBackOffManagerFactoryimplementations.The base implementation for theMessageListenerContainer.Invoked by a listener container with remaining, unprocessed, records (including the failed record).Deprecated.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 forErrorHandlerandBatchErrorHandlerand their sub-interfaces.Deprecated.in favor ofCommonErrorHandler.Deprecated.in favor ofCommonErrorHandler.AConsumerRecordRecovererthat supports getting a reference to theConsumer.Common consumer properties.ABiConsumerextension for recovering consumer records.Listeners that implement this interface are provided with aConsumerSeekAware.ConsumerSeekCallbackwhich 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.Contains runtime properties for a listener container.The offset commit behavior enumeration.Offset commit behavior during assignment.Mode for exactly once semantics.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.A component implementing this interface can provide the next delivery attempt.Deprecated.in favor ofCommonErrorHandler.Supports exception classification.Subclass ofFailedRecordProcessorthat 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.Creates aKafkaBackOffManagerFactoryinstance.Interface for backing off aMessageListenerContaineruntil 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@KafkaListenermethod throws an exception.Single-threaded Message listener container using the JavaConsumersupporting auto-partition assignment or user-configured assignment.A registry for listener containers.The listener specificKafkaExceptionextension.Defines the listener type.Listener for handling individual incoming Kafka messages.Internal abstraction used by the framework representing a message listener container.An interceptor forConsumerRecordinvoked 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.A general interface for managing thread-bound resources when aConsumeris available. -
Classes in org.springframework.kafka.listener used by org.springframework.kafka.listener.adapterClassDescriptionListener 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
BiConsumerextension for recovering consumer records.Listeners that implement this interface are provided with aConsumerSeekAware.ConsumerSeekCallbackwhich 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 aMessageListenerContaineruntil a given dueTimestamp, if such timestamp is in the future.An error handler which is called when a@KafkaListenermethod throws an exception.Defines the listener type.Listener for handling individual incoming Kafka messages. -
Classes in org.springframework.kafka.listener used by org.springframework.kafka.requestreplyClassDescriptionListener 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.Top level interface for listeners.Generic message listener container; adds parameters.
-
Classes in org.springframework.kafka.listener used by org.springframework.kafka.retrytopicClassDescriptionReplacement for
ErrorHandlerandBatchErrorHandlerand their sub-interfaces.Creates 1 or moreKafkaMessageListenerContainers based onconcurrency.Contains runtime properties for a listener container.AConsumerRecordRecovererthat publishes a failed record to a dead-letter topic.Supports exception classification.Interface for backing off aMessageListenerContaineruntil a given dueTimestamp, if such timestamp is in the future.A top level abstract class for classes that can be configured with aKafkaException.Level. -
Classes in org.springframework.kafka.listener used by org.springframework.kafka.streams
CommonErrorHandler.