Package org.springframework.integration.kafka.inbound

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.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.springframework.integration.acks.AcknowledgmentCallback

    AcknowledgmentCallback.Status

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, org.springframework.kafka.listener.ConsumerProperties consumerProperties)
    Construct an instance with the provided properties.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    acknowledge()
    Acknowledge the message delivery.
    void
    acknowledge(AcknowledgmentCallback.Status status)
    Acknowledge the message.
    boolean
    isAcknowledged()
    Implementations must implement this to indicate when the ack has been processed by the user so that the framework can auto-ack if needed.
    boolean
    isAutoAck()
    Return true if this acknowledgment supports auto ack when it has not been already ack'd by the application.
    void
    noAutoAck()
    Disable auto acknowledgment by a SourcePollingChannelAdapter or MessageSourcePollingTemplate.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.springframework.kafka.support.Acknowledgment

    acknowledge, isOutOfOrderCommit, nack, nack

  • 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