Spring Integration Kafka Support

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.
KafkaMessageListenerContainer  
LoggingErrorHandler  
MetadataStoreOffsetManager An OffsetManager that persists offsets into a MetadataStore.
 

Package org.springframework.integration.kafka.listener Description

Provides message listener container support


Spring Integration Kafka Support