Package org.springframework.kafka.listener

Package for kafka listeners

See: Description

Interface Summary

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.
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, for example to adjust offsets after an error.
ConsumerAwareMessageListener<K,V>	Listener for handling individual incoming Kafka messages.
ConsumerAwareRebalanceListener	A rebalance listener that provides access to the consumer object.
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.
ErrorHandler	Handles errors thrown during the execution of a MessageListener.
GenericErrorHandler<T>	A generic error handler.
GenericMessageListener<T>	Top level interface for listeners.
KafkaListenerErrorHandler	An error handler which is called when a {code @KafkaListener} method throws an exception.
MessageListener<K,V>	Listener for handling individual incoming Kafka messages.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
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 Summary

Class	Description
AbstractMessageListenerContainer<K,V>	The base implementation for the MessageListenerContainer.
BatchLoggingErrorHandler	Simple handler that invokes a LoggingErrorHandler for each record.
ConcurrentMessageListenerContainer<K,V>	Creates 1 or more KafkaMessageListenerContainers based on concurrency.
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.
KafkaMessageListenerContainer<K,V>	Single-threaded Message listener container using the Java Consumer supporting auto-partition assignment or user-configured assignment.
ListenerUtils	Listener utilities.
LoggingErrorHandler	The ErrorHandler implementation for logging purpose.
SeekToCurrentBatchErrorHandler	An error handler that seeks to the current offset for each topic in batch of records.
SeekToCurrentErrorHandler	An error handler that seeks to the current offset for each topic in the remaining records.

Enum Summary

Enum	Description
AbstractMessageListenerContainer.AckMode	The offset commit behavior enumeration.
ListenerType	Defines the listener type.

Exception Summary

Exception	Description
ListenerExecutionFailedException	The listener specific KafkaException extension.

Package org.springframework.kafka.listener Description

Package for kafka listeners