Package org.springframework.integration.kafka.inbound

Provides Spring Integration inbound components for Apache Kafka.

Interface Summary

Interface	Description
KafkaMessageSource.KafkaAckInfo<K,V>	Information for building an KafkaAckCallback.

Class Summary

Class	Description
KafkaInboundGateway<K,V,R>	Inbound gateway.
KafkaMessageDrivenChannelAdapter<K,V>	Message-driven channel adapter.
KafkaMessageSource<K,V>	Polled message source for Apache Kafka.
KafkaMessageSource.KafkaAckCallback<K,V>	AcknowledgmentCallback for Kafka.
KafkaMessageSource.KafkaAckCallbackFactory<K,V>	AcknowledgmentCallbackFactory for KafkaAckInfo.

Enum Summary

Enum	Description
KafkaMessageDrivenChannelAdapter.ListenerMode	The listener mode for the container, record or batch.