K - 鍵の型。V - 値の型。public static class KafkaMessageSource.KafkaAckCallback<K,V> extends ObjectSE implements AcknowledgmentCallback, org.springframework.kafka.support.Acknowledgment
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 による自動確認を無効にします。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K,V> ackInfo, @Nullable org.springframework.kafka.listener.ConsumerProperties consumerProperties)
ackInfo - ack 情報。consumerProperties - コンシューマーの特性 - コミット関連のプロパティのみが使用されます。public void acknowledge(AcknowledgmentCallback.Status status)
AcknowledgmentCallbackAcknowledgmentCallback の acknowledge status - ステータス。public boolean isAcknowledged()
AcknowledgmentCallbackAcknowledgmentCallback の isAcknowledged public void acknowledge()
SimpleAcknowledgmentAcknowledgmentCallback の acknowledge SimpleAcknowledgment の acknowledge org.springframework.kafka.support.Acknowledgment の acknowledge public void noAutoAck()
AcknowledgmentCallbackSourcePollingChannelAdapter または MessageSourcePollingTemplate による自動確認を無効にします。すべての実装がこれをサポートしているわけではありません - たとえば、Kafka メッセージソース。AcknowledgmentCallback の noAutoAck public boolean isAutoAck()
AcknowledgmentCallbackAcknowledgmentCallback の isAutoAck