|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
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 Summary | |
---|---|
AbstractDecodingMessageListener<K,P> | Base MessageListener implementation that decodes the key and the payload using the supplied
Decoder s. |
AbstractOffsetManager | Base implementation for 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.KeyEncoderDecoder | |
LoggingErrorHandler | |
LongEncoderDecoder | Kafka Encoder and Decoder for Long values. |
MetadataStoreOffsetManager | An OffsetManager that persists offsets into a MetadataStore . |
Provides message listener container support
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |