|
Spring Integration Kafka Support | ||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||
See:
Description
| Interface Summary | |
|---|---|
| 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 Summary | |
|---|---|
| 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.KeyEncoderDecoder | |
| LoggingErrorHandler | |
| LongEncoderDecoder | Kafka Encoder and Decoder for Long values. |
| MetadataStoreOffsetManager | An OffsetManager that persists offsets into a MetadataStore. |
Provides message listener container support
|
Spring Integration Kafka Support | ||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||