インターフェース KafkaMessageSource.KafkaAckInfo<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
すべてのスーパーインターフェース:
ComparableSE<KafkaMessageSource.KafkaAckInfo<K,V>>
すべての既知の実装クラス:
KafkaMessageSource.KafkaAckInfoImpl
含まれているクラス:
KafkaMessageSource<K,V>
public static interface KafkaMessageSource.KafkaAckInfo<K,V> extends ComparableSE<KafkaMessageSource.KafkaAckInfo<K,V>>
KafkaAckCallback を構築するための情報。
導入:
5.4
作成者:
Gary Russell, Mark Norkin, Artem Bilan, Anshul Mehra, Christian Tzolov, Ngoc Nhan, Jooyoung Pyoung

  • メソッドの詳細

    • getConsumerMonitor

      ObjectSE getConsumerMonitor()

    • getGroupId

      @Nullable StringSE getGroupId()

    • getConsumer

      @Nullable 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

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

    • isRolledBack

      boolean isRolledBack()

    • setRolledBack

      void setRolledBack(boolean rolledBack)

    • isAckDeferred

      boolean isAckDeferred()

    • setAckDeferred

      void setAckDeferred(boolean ackDeferred)