Package org.springframework.kafka.listener

Package for kafka listeners

See: Description

Interface Summary

Interface	Description
AcknowledgingMessageListener<K,V>	Listener for handling 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.
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.
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.
ErrorHandler	Handles errors thrown during the execution of a MessageListener.
GenericAcknowledgingMessageListener<T>	Top level interface for acknowledging listener types.
GenericErrorHandler<T>	A generic error handler.
GenericMessageListener<T>	Top level interface for listener types using container or auto commits.
KafkaDataListener<T>	Marker interface for all listeners.
MessageListener<K,V>	Listener for handling individual incoming Kafka messages.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.

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.
KafkaMessageListenerContainer<K,V>	Single-threaded Message listener container using the Java Consumer supporting auto-partition assignment or user-configured assignment.
LoggingErrorHandler	The ErrorHandler implementation for logging purpose.

Enum Summary

Enum	Description
AbstractMessageListenerContainer.AckMode	The offset commit behavior enumeration.

Exception Summary

Exception	Description
ListenerExecutionFailedException	The listener specific KafkaException extension.

Package org.springframework.kafka.listener Description

Package for kafka listeners