インターフェース KafkaInboundEndpoint
- すべての既知の実装クラス:
KafkaInboundGateway,KafkaMessageDrivenChannelAdapter
public interface KafkaInboundEndpoint
このインターフェースの実装は、通常、受信配信を再試行するための再試行テンプレートをサポートし、これは再試行コンテキストへの共通属性の追加をサポートします。
- 導入:
- 6.0
- 作成者:
- Gary Russell
フィールドサマリー
フィールド修飾子と型フィールド説明static final ThreadLocalSE<AttributeAccessor>static final StringSEリスナーが確認応答できる場合の確認応答のRetryContext属性キー。static final StringSEリスナーがコンシューマー対応である場合のコンシューマーのRetryContext属性キー。static final StringSEレコードのRetryContext属性キー。メソッドのサマリー
修飾子と型メソッド説明default voiddoWithRetry(org.springframework.retry.support.RetryTemplate template, org.springframework.retry.RecoveryCallback<?> callback, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.springframework.kafka.support.Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, RunnableSE runnable) 再試行テンプレートと回復コールバックを使用してランナブルを実行します。
フィールドの詳細
メソッドの詳細
doWithRetry
default void doWithRetry(org.springframework.retry.support.RetryTemplate template, org.springframework.retry.RecoveryCallback<?> callback, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, org.springframework.kafka.support.Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, RunnableSE runnable) 再試行テンプレートと回復コールバックを使用してランナブルを実行します。- パラメーター:
template- テンプレート。callback- コールバック。record- レコード (またはレコード)。acknowledgment- 承認。consumer- コンシューマー。runnable- ランナブル。