Package org.springframework.integration.kafka.listener

Provides message listener container support

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 Decoders.
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.
 

Package org.springframework.integration.kafka.listener Description

Provides message listener container support