パッケージ org.springframework.integration.kafka.inbound

インターフェース 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 を構築するための情報。

  • 方法の詳細

    • getConsumerMonitor

      ObjectSE getConsumerMonitor()

    • getGroupId

      StringSE 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

      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)