| Interface | Description |
|---|---|
| AcknowledgingConsumerAwareMessageListener<K,V> |
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients
can invoke when the message has been processed.
|
| AcknowledgingMessageListener<K,V> |
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients
can invoke when the message has been processed.
|
| AfterRollbackProcessor<K,V> |
Invoked by a listener container with remaining, unprocessed, records
(including the failed record).
|
| BatchAcknowledgingConsumerAwareMessageListener<K,V> |
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment
handle that recipients can invoke when the message has been processed.
|
| BatchAcknowledgingMessageListener<K,V> |
Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment
handle that recipients can invoke when the message has been processed.
|
| BatchConsumerAwareMessageListener<K,V> |
Listener for handling a batch of incoming Kafka messages; the list
is created from the consumer records object returned by a poll.
|
| BatchErrorHandler |
Handles errors thrown during the execution of a
BatchMessageListener. |
| 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.
|
| ConsumerAwareBatchErrorHandler |
An error handler that has access to the consumer, for example to adjust
offsets after an error.
|
| ConsumerAwareErrorHandler |
An error handler that has access to the consumer, for example to adjust
offsets after an error.
|
| ConsumerAwareListenerErrorHandler |
An error handler that has access to the consumer.
|
| ConsumerAwareMessageListener<K,V> |
Listener for handling individual incoming Kafka messages.
|
| ConsumerAwareRebalanceListener |
A rebalance listener that provides access to the consumer object.
|
| 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.
|
| ContainerAwareBatchErrorHandler |
An error handler that has access to the batch of records from the last poll the
consumer, and the container.
|
| ContainerAwareErrorHandler |
An error handler that has access to the unprocessed records from the last poll
(including the failed record), the consumer, and the container.
|
| DelegatingMessageListener<T> |
Classes implementing this interface allow containers to determine the type of the
ultimate listener.
|
| DeliveryAttemptAware |
A component implementing this interface can provide the next delivery attempt.
|
| ErrorHandler |
Handles errors thrown during the execution of a
MessageListener. |
| GenericErrorHandler<T> |
A generic error handler.
|
| GenericMessageListener<T> |
Top level interface for listeners.
|
| GenericMessageListenerContainer<K,V> |
Generic message listener container; adds parameters.
|
| KafkaListenerErrorHandler |
An error handler which is called when a
@KafkaListener method
throws an exception. |
| ListenerInvokingBatchErrorHandler |
A batch error handler that is capable of invoking the listener during error handling.
|
| MessageListener<K,V> |
Listener for handling individual incoming Kafka messages.
|
| MessageListenerContainer |
Internal abstraction used by the framework representing a message
listener container.
|
| RecordInterceptor<K,V> |
An interceptor for
ConsumerRecord invoked by the listener
container before invoking the listener. |
| RemainingRecordsErrorHandler |
An error handler that has access to the unprocessed records from the last poll
(including the failed record) and the consumer, for example to adjust offsets after an
error.
|
| Class | Description |
|---|---|
| AbstractConsumerSeekAware |
Manages the
ConsumerSeekAware.ConsumerSeekCallback s for the listener. |
| AbstractMessageListenerContainer<K,V> |
The base implementation for the
MessageListenerContainer. |
| BatchLoggingErrorHandler |
Simple handler that invokes a
LoggingErrorHandler for each record. |
| CompositeRecordInterceptor<K,V> |
A
RecordInterceptor that delegates to one or more RecordInterceptor in
order. |
| ConcurrentMessageListenerContainer<K,V> |
Creates 1 or more
KafkaMessageListenerContainers based on
concurrency. |
| ConsumerProperties |
Common consumer properties.
|
| ContainerProperties |
Contains runtime properties for a listener container.
|
| ContainerStoppingBatchErrorHandler |
A container error handler that stops the container after an exception
is thrown by the listener.
|
| ContainerStoppingErrorHandler |
A container error handler that stops the container after an exception
is thrown by the listener.
|
| DeadLetterPublishingRecoverer |
A
ConsumerRecordRecoverer that publishes a failed record to a dead-letter
topic. |
| DefaultAfterRollbackProcessor<K,V> |
Default implementation of
AfterRollbackProcessor. |
| FailedRecordProcessor |
Common super class for classes that deal with failing to consume a consumer record.
|
| KafkaExceptionLogLevelAware |
A top level abstract class for classes that can be configured with a
KafkaException.Level. |
| KafkaMessageListenerContainer<K,V> |
Single-threaded Message listener container using the Java
Consumer supporting
auto-partition assignment or user-configured assignment. |
| ListenerUtils |
Listener utilities.
|
| LoggingCommitCallback |
Logs commit results at DEBUG level for success and ERROR for failures.
|
| LoggingErrorHandler |
The
ErrorHandler implementation for logging purpose. |
| RecoveringBatchErrorHandler |
An error handler that seeks to the current offset for each topic in a batch of records.
|
| RetryingBatchErrorHandler |
A batch error handler that invokes the listener according to the supplied
BackOff. |
| SeekToCurrentBatchErrorHandler |
An error handler that seeks to the current offset for each topic in a batch of records.
|
| SeekToCurrentErrorHandler |
An error handler that seeks to the current offset for each topic in the remaining
records.
|
| SeekUtils |
Seek utilities.
|
| Enum | Description |
|---|---|
| ContainerProperties.AckMode |
The offset commit behavior enumeration.
|
| ContainerProperties.AssignmentCommitOption |
Offset commit behavior during assignment.
|
| ContainerProperties.EOSMode |
Mode for exactly once semantics.
|
| ListenerType |
Defines the listener type.
|
| Exception | Description |
|---|---|
| BatchListenerFailedException |
An exception thrown by user code to inform the framework which record in a batch has
failed.
|
| ListenerExecutionFailedException |
The listener specific
KafkaException extension. |