Package org.springframework.integration.kafka.listener

Provides message listener container support

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.
 

Package org.springframework.integration.kafka.listener Description

Provides message listener container support