Package org.springframework.integration.kafka.inbound

package org.springframework.integration.kafka.inbound

Provides Spring Integration inbound components for Apache Kafka.

Class	Description
KafkaErrorSendingMessageRecoverer	An extension of ErrorMessagePublisher that can be used in a CommonErrorHandler for recovering Kafka delivery failures.
KafkaInboundEndpoint	Implementations of this interface will generally support a retry template for retrying incoming deliveries and this supports adding common attributes to the retry context.
KafkaInboundGateway<K,V,R>	Inbound gateway.
KafkaMessageDrivenChannelAdapter<K,V>	Message-driven channel adapter.
KafkaMessageDrivenChannelAdapter.ListenerMode	The listener mode for the container, record or batch.
KafkaMessageSource<K,V>	Polled message source for Apache Kafka.
KafkaMessageSource.KafkaAckCallback<K,V>	AcknowledgmentCallback for Kafka.
KafkaMessageSource.KafkaAckCallbackFactory<K,V>	AcknowledgmentCallbackFactory for KafkaAckInfo.
KafkaMessageSource.KafkaAckInfo<K,V>	Information for building an KafkaAckCallback.