パッケージの使用
org.springframework.kafka.retrytopic
org.springframework.kafka.retrytopic を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
再試行可能なトピック処理用のパッケージ。
- クラス説明
DestinationTopicResolverを使用してメッセージを転送するために使用されるDeadLetterPublishingRecovererを作成および構成します。このインターフェースを実装して、各DeadLetterPublishingRecovererを作成します。再試行トピックや dlt など、メッセージの転送先となる宛先トピックの表現。DestinationTopicインスタンスを保存および取得するためのメソッドを提供します。DestinationTopicProcessorは、提供されたDestinationTopicProcessor.ContextにDestinationTopicインスタンスを作成して登録し、コンテキストプロパティで呼び出されるコールバックインターフェースも提供します。提供された構成に基づいてDestinationTopic.Propertiesのリストを作成します。処理に失敗したメッセージの転送先となる宛先を解決するためのメソッドを提供します。DLT 処理を処理するための戦略。トピックの再試行機能でメイン、再試行、DLT エンドポイントをカスタマイズし、結果のトピック名を返します。付属のConcurrentKafkaListenerContainerFactoryを装飾して、DefaultErrorHandlerとDeadLetterPublishingRecovererFactoryによって作成されたDeadLetterPublishingRecovererを追加します。RetryTopicConfigurationによって使用されるConcurrentKafkaListenerContainerFactoryを解決します。RetryTopicConfigurationSupportで使用されるコンポーネントインスタンスを提供します。再試行可能なトピック用に提供された構成が含まれています。RetryTopicConfigurationインスタンスを作成するためのビルダークラス。ノンブロッキングで使用されるブロッキング再試行を構成します。トピックの再試行機能によってインスタンス化されたコンポーネントのカスタマイザーを構成します。メインエンドポイントと提供された構成に基づいてメイン、再試行、DLT トピックを構成し、順序の保証を犠牲にしてノンブロッキング方式で分散再試行 /DLT パターンを実現します。再試行およびデッドレタートピックに関連する命名を処理します。再試行トピックのためにパーティションが一時停止されたときにコンテナーの再開をスケジュールするために使用するTaskSchedulerのラッパークラス。複数の連続した再試行のバックオフ間隔が同じ場合のトピック再利用の戦略。RetryTopic 機能の定数。