Class KafkaMessageSource.KafkaAckCallback<K,V>

java.lang.Object
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback<K,V>
Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
AcknowledgmentCallback, SimpleAcknowledgment, org.springframework.kafka.support.Acknowledgment
Enclosing class:
KafkaMessageSource<K,V>

public static class KafkaMessageSource.KafkaAckCallback<K,V> extends Object implements AcknowledgmentCallback, org.springframework.kafka.support.Acknowledgment
AcknowledgmentCallback for Kafka.
  • Constructor Details

    • KafkaAckCallback

      public KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, @Nullable org.springframework.kafka.listener.ConsumerProperties consumerProperties)
      Construct an instance with the provided properties.
      Parameters:
      ackInfo - the ack info.
      consumerProperties - the consumer properties - only commit-related properties are used.
  • Method Details