Uses of Record Class
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory

Packages that use KafkaMessageSource.KafkaAckCallbackFactory

Package	Description
org.springframework.integration.kafka.dsl	Provides Spring Integration Java DSL Components support for Apache Kafka.
org.springframework.integration.kafka.inbound	Provides Spring Integration inbound components for Apache Kafka.

Uses of KafkaMessageSource.KafkaAckCallbackFactory in org.springframework.integration.kafka.dsl

Methods in org.springframework.integration.kafka.dsl with parameters of type KafkaMessageSource.KafkaAckCallbackFactory

Modifier and Type	Method	Description
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics with a custom ack callback factory.
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, boolean allowMultiFetch)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics with a custom ack callback factory.

Uses of KafkaMessageSource.KafkaAckCallbackFactory in org.springframework.integration.kafka.inbound

Constructors in org.springframework.integration.kafka.inbound with parameters of type KafkaMessageSource.KafkaAckCallbackFactory

Modifier	Constructor	Description
	KafkaMessageSource(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory)	Construct an instance with the supplied parameters.
	KafkaMessageSource(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, boolean allowMultiFetch)	Construct an instance with the supplied parameters.