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