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

クラス KafkaMessageSource.KafkaAckCallback<K, V>

java.lang.ObjectSE
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
AcknowledgmentCallback、SimpleAcknowledgment、org.springframework.kafka.support.Acknowledgment
含まれているクラス:
KafkaMessageSource<K,V>
public static class KafkaMessageSource.KafkaAckCallback<K,V> extends ObjectSE implements AcknowledgmentCallback, org.springframework.kafka.support.Acknowledgment
Kafka の場合は AcknowledgmentCallback。

  • ネストされたクラスのサマリー

    インターフェース org.springframework.integration.acks.AcknowledgmentCallback から継承されたネストクラス / インターフェース

    AcknowledgmentCallback.Status

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, org.springframework.kafka.listener.ConsumerProperties consumerProperties)
    提供されたプロパティを使用してインスタンスを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    acknowledge()
    メッセージの配信を確認します。
    void
    acknowledge(AcknowledgmentCallback.Status status)
    メッセージを確認します。
    boolean
    isAcknowledged()
    フレームワークが必要に応じて自動確認できるように、実装はこれを実装してユーザーが確認を処理したことを示す必要があります。
    boolean
    isAutoAck()
    アプリケーションによってまだ確認されていない場合に、この確認が自動確認をサポートする場合は true を返します。
    void
    noAutoAck()
    SourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース org.springframework.kafka.support.Acknowledgment から継承されたメソッド

    acknowledge, isOutOfOrderCommit, nack, nack

  • コンストラクターの詳細

    • KafkaAckCallback

      public KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, @Nullable org.springframework.kafka.listener.ConsumerProperties consumerProperties)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      ackInfo - ack 情報。
      consumerProperties - コンシューマーの特性 - コミット関連のプロパティのみが使用されます。

  • メソッドの詳細

    • acknowledge

      public void acknowledge(AcknowledgmentCallback.Status status)
      インターフェースからコピーされた説明: AcknowledgmentCallback
      メッセージを確認します。
      次で指定:
      インターフェース AcknowledgmentCallback の acknowledge 
      パラメーター:
      status - ステータス。

    • isAcknowledged

      public boolean isAcknowledged()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      フレームワークが必要に応じて自動確認できるように、実装はこれを実装してユーザーが確認を処理したことを示す必要があります。
      次で指定:
      インターフェース AcknowledgmentCallback の isAcknowledged 
      戻り値:
      メッセージがすでに確認されている場合は true。

    • acknowledge

      public void acknowledge()
      インターフェースからコピーされた説明: SimpleAcknowledgment
      メッセージの配信を確認します。
      次で指定:
      インターフェース org.springframework.kafka.support.Acknowledgment の acknowledge 
      次で指定:
      インターフェース AcknowledgmentCallback の acknowledge 
      次で指定:
      インターフェース SimpleAcknowledgment の acknowledge 

    • noAutoAck

      public void noAutoAck()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      SourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。すべての実装がこれをサポートしているわけではありません - たとえば、Kafka メッセージソース。
      次で指定:
      インターフェース AcknowledgmentCallback の noAutoAck 

    • isAutoAck

      public boolean isAutoAck()
      インターフェースからコピーされた説明: AcknowledgmentCallback
      アプリケーションによってまだ確認されていない場合に、この確認が自動確認をサポートする場合は true を返します。
      次で指定:
      インターフェース AcknowledgmentCallback の isAutoAck 
      戻り値:
      自動確認がサポートされている場合は true。