Uses of Interface
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckInfo
Package
Description
Provides Spring Integration inbound components for Apache Kafka.
-
Uses of KafkaMessageSource.KafkaAckInfo in org.springframework.integration.kafka.inbound
Modifier and TypeClassDescriptionclass
Information for building an KafkaAckCallback.Modifier and TypeMethodDescriptionMap<org.apache.kafka.common.TopicPartition,
Set<KafkaMessageSource.KafkaAckInfo<K, V>>> KafkaMessageSource.KafkaAckInfo.getOffsets()
Map<org.apache.kafka.common.TopicPartition,
Set<KafkaMessageSource.KafkaAckInfo<K, V>>> KafkaMessageSource.KafkaAckInfoImpl.getOffsets()
Modifier and TypeMethodDescriptionint
KafkaMessageSource.KafkaAckInfoImpl.compareTo
(KafkaMessageSource.KafkaAckInfo<K, V> other) KafkaMessageSource.KafkaAckCallbackFactory.createCallback
(KafkaMessageSource.KafkaAckInfo<K, V> info) ModifierConstructorDescriptionKafkaAckCallback
(KafkaMessageSource.KafkaAckInfo<K, V> ackInfo, org.springframework.kafka.listener.ConsumerProperties consumerProperties) Construct an instance with the provided properties.