Uses of Package
org.springframework.kafka.listener

Packages that use org.springframework.kafka.listener

Package	Description
org.springframework.kafka.config	Package for kafka configuration
org.springframework.kafka.listener	Package for kafka listeners
org.springframework.kafka.listener.adapter	Provides classes for adapting listeners.
org.springframework.kafka.requestreply	Provides classes for request/reply semantics.
org.springframework.kafka.retrytopic	Package for retryable topic handling.
org.springframework.kafka.streams	Package for classes related to Kafka Streams.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.config

Class	Description
AbstractMessageListenerContainer	The base implementation for the MessageListenerContainer.
AfterRollbackProcessor	Invoked by a listener container with remaining, unprocessed, records (including the failed record).
BatchInterceptor	An interceptor for batches of records.
CommonErrorHandler	Listener container error handling contract.
ConcurrentMessageListenerContainer	Creates 1 or more KafkaMessageListenerContainers based on concurrency.
ContainerProperties	Contains runtime properties for a listener container.
KafkaListenerErrorHandler	An error handler which is called when a @KafkaListener method throws an exception.
ListenerContainerRegistry	A registry for listener containers.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
RecordInterceptor	An interceptor for ConsumerRecord invoked by the listener container before and after invoking the listener.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.listener

Class	Description
AbstractKafkaBackOffManagerFactory	Base class for KafkaBackOffManagerFactory implementations.
AbstractMessageListenerContainer	The base implementation for the MessageListenerContainer.
AfterRollbackProcessor	Invoked by a listener container with remaining, unprocessed, records (including the failed record).
BackOffHandler	Handler for the provided back off time, listener container and exception.
BatchInterceptor	An interceptor for batches of records.
BatchMessageListener	Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
CommonErrorHandler	Listener container error handling contract.
ConsumerAwareRecordRecoverer	A ConsumerRecordRecoverer that supports getting a reference to the Consumer.
ConsumerPauseResumeEventPublisher	Objects that can publish consumer pause/resume events.
ConsumerProperties	Common consumer properties.
ConsumerRecordRecoverer	A BiConsumer extension for recovering consumer records.
ConsumerSeekAware	Listeners that implement this interface are provided with a ConsumerSeekAware.ConsumerSeekCallback which can be used to perform a seek operation.
ConsumerSeekAware.ConsumerSeekCallback	A callback that a listener can invoke to seek to a specific offset.
ContainerProperties	Contains runtime properties for a listener container.
ContainerProperties.AckMode	The offset commit behavior enumeration.
ContainerProperties.AssignmentCommitOption	Offset commit behavior during assignment.
ContainerProperties.EOSMode	Mode for exactly once semantics.
DeadLetterPublishingRecoverer.ExceptionHeadersCreator	Use this to provide a custom implementation to take complete control over exception header creation for the output record.
DeadLetterPublishingRecoverer.HeaderNames	Container class for the name of the headers that will be added to the produced record.
DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo	Headers for data relative to the exception thrown.
DeadLetterPublishingRecoverer.HeaderNames.Builder.Original	Headers for data relative to the original record.
DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo	Header names for exception headers.
DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd	Bits representing which headers to add.
DeadLetterPublishingRecoverer.HeaderNames.Original	Header names for original record property headers.
DeliveryAttemptAware	A component implementing this interface can provide the next delivery attempt.
ExceptionClassifier	Supports exception classification.
FailedBatchProcessor	Subclass of FailedRecordProcessor that can process (and recover) a batch.
FailedRecordProcessor	Common super class for classes that deal with failing to consume a consumer record.
GenericMessageListener	Top level interface for listeners.
GenericMessageListenerContainer	Generic message listener container; adds parameters.
KafkaBackOffManagerFactory	Creates a KafkaBackOffManagerFactory instance.
KafkaConsumerBackoffManager	Interface for backing off a MessageListenerContainer until a given dueTimestamp, if such timestamp is in the future.
KafkaConsumerBackoffManager.Context	Provides the state that will be used for backing off.
KafkaExceptionLogLevelAware	A top level abstract class for classes that can be configured with a KafkaException.Level.
KafkaListenerErrorHandler	An error handler which is called when a @KafkaListener method throws an exception.
KafkaMessageListenerContainer	Single-threaded Message listener container using the Java Consumer supporting auto-partition assignment or user-configured assignment.
ListenerContainerPauseService	Service for pausing and resuming of MessageListenerContainer.
ListenerContainerRegistry	A registry for listener containers.
ListenerExecutionFailedException	The listener specific KafkaException extension.
ListenerMetadata	Metadata associated to a KafkaListener.
ListenerType	Defines the listener type.
MessageListener	Listener for handling individual incoming Kafka messages.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
OffsetAndMetadataProvider	Provider for OffsetAndMetadata.
RecordInterceptor	An interceptor for ConsumerRecord invoked by the listener container before and after invoking the listener.
RecoveryStrategy	Called to determine whether a record should be skipped.
RetryListener	A listener for retry activity.
ThreadStateProcessor	A general interface for managing thread-bound resources when a Consumer is available.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.listener.adapter

Class	Description
AcknowledgingConsumerAwareMessageListener	Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
BatchAcknowledgingConsumerAwareMessageListener	Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
BatchMessageListener	Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
ConsumerRecordRecoverer	A BiConsumer extension for recovering consumer records.
ConsumerSeekAware	Listeners that implement this interface are provided with a ConsumerSeekAware.ConsumerSeekCallback which can be used to perform a seek operation.
ConsumerSeekAware.ConsumerSeekCallback	A callback that a listener can invoke to seek to a specific offset.
DelegatingMessageListener	Classes implementing this interface allow containers to determine the type of the ultimate listener.
GenericMessageListener	Top level interface for listeners.
KafkaBackoffException	Exception thrown when the consumer should not yet consume the message due to backOff.
KafkaConsumerBackoffManager	Interface for backing off a MessageListenerContainer until a given dueTimestamp, if such timestamp is in the future.
KafkaListenerErrorHandler	An error handler which is called when a @KafkaListener method throws an exception.
ListenerType	Defines the listener type.
MessageListener	Listener for handling individual incoming Kafka messages.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.requestreply

Class	Description
BatchConsumerAwareMessageListener	Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
BatchMessageListener	Listener for handling a batch of incoming Kafka messages; the list is created from the consumer records object returned by a poll.
ConsumerSeekAware	Listeners that implement this interface are provided with a ConsumerSeekAware.ConsumerSeekCallback which can be used to perform a seek operation.
GenericMessageListener	Top level interface for listeners.
GenericMessageListenerContainer	Generic message listener container; adds parameters.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.retrytopic

Class	Description
CommonErrorHandler	Listener container error handling contract.
ConcurrentMessageListenerContainer	Creates 1 or more KafkaMessageListenerContainers based on concurrency.
DeadLetterPublishingRecoverer	A ConsumerRecordRecoverer that publishes a failed record to a dead-letter topic.
DefaultErrorHandler	An error handler that, for record listeners, seeks to the current offset for each topic in the remaining records.
ExceptionClassifier	Supports exception classification.
KafkaBackOffManagerFactory	Creates a KafkaBackOffManagerFactory instance.
KafkaConsumerBackoffManager	Interface for backing off a MessageListenerContainer until a given dueTimestamp, if such timestamp is in the future.
KafkaExceptionLogLevelAware	A top level abstract class for classes that can be configured with a KafkaException.Level.
ListenerContainerRegistry	A registry for listener containers.

Classes in org.springframework.kafka.listener used by org.springframework.kafka.streams

Class	Description
ConsumerRecordRecoverer	A BiConsumer extension for recovering consumer records.