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 Decoder s. |
AbstractDecodingMessageListener<K,P> |
Base
MessageListener implementation that decodes the key and the payload using the supplied
Decoder s. |
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 . |