| 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.
|
| ErrorHandler |
Handles errors thrown during the execution of a
MessageListener. |
| MessageListener<K,V> |
Listener for handling incoming Kafka messages.
|
| MessageListenerContainer |
Internal abstraction used by the framework representing a message
listener container.
|
| Class | Description |
|---|---|
| AbstractMessageListenerContainer<K,V> |
The base implementation for the
MessageListenerContainer. |
| 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 | Description |
|---|---|
| AbstractMessageListenerContainer.AckMode |
The offset commit behavior enumeration.
|
| Exception | Description |
|---|---|
| ListenerExecutionFailedException |
The listener specific
KafkaException extension. |