Interface KafkaMessageSource.KafkaAckInfo<K,V>

Type Parameters:
K - the key type.
V - the value type.
All Superinterfaces:
Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
All Known Implementing Classes:
KafkaMessageSource.KafkaAckInfoImpl
Enclosing class:
KafkaMessageSource<K,V>
public static interface KafkaMessageSource.KafkaAckInfo<K,V> extends Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
Information for building an KafkaAckCallback.
Since:
5.4
Author:
Gary Russell, Mark Norkin, Artem Bilan, Anshul Mehra, Christian Tzolov, Ngoc Nhan

  • Method Details

    • getConsumerMonitor

      Object getConsumerMonitor()

    • getGroupId

      String getGroupId()

    • getConsumer

      org.apache.kafka.clients.consumer.Consumer<K,V> getConsumer()

    • getRecord

      org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getRecord()

    • getTopicPartition

      org.apache.kafka.common.TopicPartition getTopicPartition()

    • getOffsets

      Map<org.apache.kafka.common.TopicPartition, Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()

    • isRolledBack

      boolean isRolledBack()

    • setRolledBack

      void setRolledBack(boolean rolledBack)

    • isAckDeferred

      boolean isAckDeferred()

    • setAckDeferred

      void setAckDeferred(boolean ackDeferred)