See: Description
| Interface | Description |
|---|---|
| AcknowledgingMessageListener |
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients
can invoke when the message has been processed.
|
| Acknowledgment |
Handle for acknowledging the processing of a
KafkaMessage. |
| ErrorHandler |
Handles errors thrown during the execution of a
MessageListener |
| MessageListener |
Listener for handling incoming Kafka messages
|
| OffsetManager |
Stores and retrieves offsets for a Kafka consumer
|
| Class | Description |
|---|---|
| AbstractDecodingAcknowledgingMessageListener<K,P> |
Base
AcknowledgingMessageListener implementation that decodes the key and the
payload using the supplied Decoders. |
| AbstractDecodingMessageListener<K,P> |
Base
MessageListener implementation that decodes the key and the payload using the supplied
Decoders. |
| AbstractOffsetManager |
Base implementation for
OffsetManager. |
| DefaultAcknowledgment |
Default implementation for an
Acknowledgment that defers to an underlying
OffsetManager. |
| KafkaMessageListenerContainer | |
| KafkaTopicOffsetManager |
Implementation of an
OffsetManager that uses a Kafka topic as the underlying support. |
| KafkaTopicOffsetManager.Key |
Wraps the partition and consumer information and will be used as a key on the Kafka topic
|
| KafkaTopicOffsetManager.KeySerializerDecoder | |
| LoggingErrorHandler | |
| LongSerializerDecoder |
Kafka
Encoder and Decoder for Long values. |
| MetadataStoreOffsetManager |
An
OffsetManager that persists offsets into a MetadataStore. |