コンストラクターの詳細

• 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
  メッセージの配信を確認します。

  次で指定:

  インターフェース AcknowledgmentCallback の acknowledge 

  次で指定:

  インターフェース SimpleAcknowledgment の acknowledge 

  次で指定:

  インターフェース org.springframework.kafka.support.Acknowledgment の acknowledge 

• noAutoAck

  public void noAutoAck()

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

  次で指定:

  インターフェース AcknowledgmentCallback の noAutoAck 

• isAutoAck

  public boolean isAutoAck()

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

  次で指定:

  インターフェース AcknowledgmentCallback の isAutoAck 

  戻り値:

  自動確認がサポートされている場合は true。