すべてのクラスとインターフェース
クラス
説明
リスナーの
ConsumerSeekAware.ConsumerSeekCallback を管理します。 すべてのリスナーアダプターの最上位クラス。
RecordFilterStrategy を介してレコードフィルターロジックを実装する抽象メッセージリスナーアダプター。 抽象型マッパー。
KafkaBackOffManagerFactory 実装の基本クラス。Kafka ヘッダーマッパーのベース。
ヘッダーのマッチャー。
ヘッダーのセットに一致しないマッチャー。
指定されたヘッダーが指定された単純なパターンに一致する場合に一致するパターンベースのヘッダーマッチャー。
Spring の基本コンテナー実装用の基本
KafkaListenerContainerFactory。Kafka リスナーエンドポイントの基本モデル。
MessageListenerContainer の基本実装。 メッセージリスナーアダプターを再試行するための基本クラス。
サーバーの 2 つのリストを切り替えることができるブートストラップサーバーの
SupplierSE。 受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。
受信 Kafka メッセージを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。
ConsumerRecord の処理を承認するためのハンドル。 リスナーアダプターのユーティリティ。
未処理のレコード (失敗したレコードを含む) が残っているリスナーコンテナーによって呼び出されます。
同じ相関 ID を持つ複数の応答を集約する応答テンプレート。
許可 / 拒否コレクションとその述語を管理するためのクラス。
このインターフェースを実装するメッセージハンドラーアダプターは、
HandlerAdapter 非同期戻り値の型を検出できます。 指定されたバックオフ時間、リスナーコンテナー、例外のハンドラー。
提供された maxAttempts 値と
BackOffPolicy からバックオフ値を生成します。 受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。
受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。
受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。
レコードのバッチのインターセプター。
バッチ内のどのレコードが失敗したかをフレームワークに通知するために、ユーザーコードによってスローされる例外。
Kafka 固有の
Message コンバーター戦略。 受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。
バッチメッセージリスナーで使用されるメッセージング
MessageConverter 実装。コンシューマーレコードの値は、メッセージペイロードのコレクションに抽出されます。 構成可能な
HandlerAdapter を呼び出す MessageListener アダプター。リスナーがメッセージのバッチを受信するようにファクトリが構成されている場合に使用されます。 バッチリスナーをレコードリスナーメソッドに適合させるアダプター。
各メッセージのコールバック。
Kafka ブローカーのアドレスをカプセル化します。
JSON メッセージコンバーター - 出力の場合は
byte[]、入力の場合は String、Bytes、byte[]。JSON メッセージコンバーター - 出力の場合は
Bytes、入力の場合は String、Bytes、byte[]。 使用すべきではありません。
メッセージの受信時にインスタンス化する必要があるクラスを作成できるように、メッセージにメタデータを設定するための戦略。
KafkaStreams.cleanUp() の実行時刻を指定します。 エラーが発生したときにコンテナーを停止する
CommonErrorHandler。 例外の種類に応じて、さまざまなエラーハンドラーに委譲するエラーハンドラー。
リスナーコンテナーのエラー処理契約。
例外をログに記録するための
CommonErrorHandler 実装。 レコードリスナーとバッチリスナーの異なる
CommonErrorHandler に委譲する CommonErrorHandler。1 つ以上の
BatchInterceptor に順番に委譲する BatchInterceptor。 コンポジット
KafkaStreamsCustomizer は、提供された KafkaStreamsCustomizer のリストに委譲することにより、KafkaStreams をカスタマイズします。 コンポジット
KafkaStreamsInfrastructureCustomizer は、提供された KafkaStreamsInfrastructureCustomizer のリストに委譲することにより、KafkaStreams をカスタマイズします。 インターセプターのコレクションに委譲する
ProducerInterceptor。 リスナーのコレクションに委譲する
ProducerListener。1 つ以上の
RecordInterceptor に順番に委譲する RecordInterceptor。 同時実行コンテナーが停止されたときに発行されるイベント。
concurrency に基づいて 1 つ以上の KafkaMessageListenerContainer を作成します。 コンシューマーにアクセスできるエラーハンドラー。
個々の受信 Kafka メッセージを処理するためのリスナー。
コンシューマーオブジェクトへのアクセスを提供するリバランスリスナー。
Consumer への参照の取得をサポートする ConsumerRecordRecoverer。Consumer インスタンスを生成する戦略。 コンシューマーが追加または削除されるたびに呼び出されます。
コンシューマーが起動に失敗したときに発行されるイベント。
コンシューマーパーティションが一時停止したときに発行されるイベント。
コンシューマーパーティションが再開されたときに発行されるイベント。
コンシューマーが一時停止したときに発行されるイベント。
コンシューマーの一時停止 / 再開イベントを発行できるオブジェクト。
新しく作成されたコンシューマーで後処理を実行するために、コンシューマーファクトリによって呼び出されます。
一般的なコンシューマープロパティ。
ユーザーがそのようなパラメーターを指定するときに、リスナーメソッドの引数を提供するために使用されます。
コンシューマーレコードを回復するための
BiConsumerSE 拡張。 コンシューマーが再開されたときに発行されるイベント。
コンシューマーの認証または認可が失敗し、再試行されているときに発行されるイベント。
コンシューマーの認証を再試行する理由。
認証または認可の再試行が成功したときに発行されるイベント。
このインターフェースを実装するリスナーには、シーク操作の実行に使用できる
ConsumerSeekAware.ConsumerSeekCallback が提供されます。 特定のオフセットをシークするためにリスナーが呼び出すことができるコールバック。
コンシューマーが起動したときに公開されるイベント。
コンシューマーが初期化するときに発行されるイベント。
コンシューマーが停止したときに発行されるイベント。
コンシューマーを停止する理由。
コンシューマーが停止したときに発行されるイベント。
コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。
リスナーコンテナーのグループ。
前のグループのすべてのコンテナーがアイドル状態のときに、コンテナーグループの開始をシーケンスします。
指定されたタイムスタンプの期限が切れていない場合に、特定のトピックの消費を取り消すマネージャー。
バックオフのためにコンテナーを一時停止する
BackOffHandler。 コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。
リスナーコンテナーのランタイムプロパティが含まれています。
オフセットコミット動作の列挙。
割り当て中のオフセットコミット動作。
厳密に 1 回のセマンティクスのモード。
コンテナー停止時に発行されるイベント。
リスナーコンテナーをテストするためのユーティリティ。
型
Continuation のメソッド引数の何もしないリゾルバー。 変換の例外。
指定された
MessageConverter を使用して受信した ConsumerRecord の変換を実装し、結果を指定された MessageListener に渡す AcknowledgingConsumerAwareMessageListener アダプター。 ハッシュキーとして使用できる byte[] のラッパー。
失敗したレコードをデッドレタートピックに公開する
ConsumerRecordRecoverer。 これを使用して、出力レコードの例外ヘッダーの作成を完全に制御するカスタム実装を提供します。
生成されたレコードに追加されるヘッダーの名前のコンテナークラス。
DeadLetterPublishingRecoverer.HeaderNames を作成するための便利な API を提供します。 例外ヘッダーのヘッダー名。
追加するヘッダーを表すビット。
元のレコードプロパティヘッダーのヘッダー名。
通常の動作であるヘッダーに追加されるのではなく、このヘッダーが既存のヘッダーをこの名前に置き換える必要があることを示す
Header。DestinationTopicResolver を使用してメッセージを転送するために使用される DeadLetterPublishingRecoverer を作成および構成します。 このインターフェースを実装して、各
DeadLetterPublishingRecoverer を作成します。AfterRollbackProcessor のデフォルト実装。 デフォルト
BackOffHandler ; バックオフのためにスレッドを一時停止します。 デフォルトの
BatchToRecordAdapter 実装。提供されたリカバリが例外をスローした場合、バッチは中止されます。それ以外の場合は、次のレコードが処理されます。DestinationTopicProcessor インターフェースのデフォルト実装。DestinationTopicResolver インターフェースのデフォルト実装。 レコードリスナーの場合、残りのレコードの各トピックの現在のオフセットを探すエラーハンドラー。
Jackson 2 型のマッパー。
ConsumerFactory.createConsumer() 呼び出しごとに、提供された MapSE configs およびオプションの Deserializer の新しい Consumer インスタンスを生成する ConsumerFactory 実装。Apache Kafka のデフォルトのヘッダーマッパー。
信頼できない型が原因でデコードできなかったヘッダーを表します。
デリゲートのラッパークラス。
トランザクションプロデューサーサフィックスを管理するための
TransactionIdSuffixStrategy 実装。 トピック名に基づいて他のデシリアライザーに委譲する
Deserializer。 トピックの直列化によって委譲するための共通コードを持つ基本クラス。
トピックパターンに基づいて他のシリアライザーに委譲する
Serializer。 型に基づいてシリアライザーに委譲します。
直列化セレクターヘッダーに基づいて他のデシリアライザーに委譲する
Deserializer。 メッセージペイロード型に基づいて
InvocableHandlerMethod に委譲します。 このインターフェースを実装するクラスにより、コンテナーは最終的なリスナーの型を決定できます。
直列化セレクターヘッダーに基づいて他のシリアライザーに委譲する
Serializer。 このインターフェースを実装するコンポーネントは、次の配信試行を提供できます。
RetryListener 実装用の DeliveryAttemptAwareRetryListener クラス。 逆直列化の失敗が発生したときに、コンシューマーレコードの値またはキーで例外が返されました。
再試行トピックや dlt など、メッセージの転送先となる宛先トピックの表現。
DestinationTopic インスタンスを保存および取得するためのメソッドを提供します。DestinationTopicProcessor は、提供された DestinationTopicProcessor.Context に DestinationTopic インスタンスを作成して登録し、コンテキストプロパティで呼び出されるコールバックインターフェースも提供します。 提供された構成に基づいて
DestinationTopic.Properties のリストを作成します。 処理に失敗したメッセージの転送先となる宛先を解決するためのメソッドを提供します。
DLT トピックメッセージを処理するメソッドを決定するためのアノテーション。
DLT 処理を処理するための戦略。
Spring for Apache Kafka ベースのテストを実行するテストクラスで指定できるアノテーション。
EmbeddedKafkaBroker 作成ロジックをカプセル化するファクトリ。 組み込みブローカーの JUnit5 条件。
KRaft を使用した組み込み Kafka ブローカー。
EmbeddedKafkaBroker の周囲の TestRule ラッパー。 組み込みの Kafka ブローカーおよび Zookeeper マネージャー。
ポートを設定できるように scala から移植しました。
AbstractKafkaListenerContainerFactory によってカバーで作成された Kafka リスナーのアノテーション付きエンドポイントを有効にします。 ノンブロッキングトピックベースの遅延再試行機能を有効にします。
デフォルトの Kafka Streams コンポーネントを有効にします。
トピックの再試行機能でメイン、再試行、DLT エンドポイントをカスタマイズし、結果のトピック名を返します。
RetryTopicConfigurer がメインエンドポイント、再試行エンドポイント、DLT エンドポイントをカスタマイズするために使用する EndpointCustomizer を作成します。 エンドポイントを再試行するためのハンドラーメソッド。
エンドポイントを再試行するためのハンドラーマルチメソッド。
例外をキャッチするデリゲートキー / 値デシリアライザは、直列化された java オブジェクトとしてヘッダーに返します。
エラー処理のためのユーティリティ。
メッセージ処理によって構成された例外がスローされたときに選択される追加の DLT を指定できるようにするアノテーション。
例外分類をサポートします。
最大経過時間ではなく最大再試行回数を指定できる
ExponentialBackOff のサブクラス。 バッチを処理（および回復）できる
FailedRecordProcessor のサブクラス。 デシリアライズエラーに関するすべてのコンテキスト情報を含むクラス。
コンシューマーレコードの消費の失敗を処理するクラスの共通スーパークラス。
RecordFilterStrategy を介してフィルターロジックを実装する BatchMessageListener アダプター。RecordFilterStrategy を介してフィルターロジックを実装する MessageListener アダプター。 リスナーのトップレベルインターフェース。
一般的なメッセージリスナーコンテナー。パラメーターを追加します。
テスト計画の最初に
EmbeddedKafkaBroker を開始し、最後に停止する TestExecutionListener。InvocableHandlerMethod または DelegatingInvocableHandler のラッパー。 ヘッダーを操作します。
SpEL 評価用のコンテナーオブジェクト。
メソッド呼び出しの結果。
メッセージの受信時にインスタンス化する必要があるクラスを作成できるように、メッセージにメタデータを設定するための戦略。
型変換の優先順位 - メソッドパラメーターまたはメッセージヘッダーから推測されます。
MimeType シリアライゼーション用の SimpleModule 拡張。Jackson JSON プロセッサーがクラスパスに存在するかどうかを確認するユーティリティ。
Jackson
ObjectMapper インスタンスのユーティリティ。 一部の Java 反復コードを単純化するための連鎖ユーティリティメソッド。
Kafka から JSON を受信し、Java オブジェクトを返すための汎用
Deserializer。JSON 形式で直列化と逆直列化を提供する
Serde。Java オブジェクトを JSON として Kafka に送信するための汎用
Serializer。 トピック / データ / ヘッダーから
JavaType を判別します。JUnit のルールと条件のユーティリティメソッド。
アプリケーションコンテキストで定義されたトピックを作成するために
Admin に委譲する管理者。 複数のトピックを単一の Bean として宣言するのを容易にする
NewTopic のコレクションのラッパー。AdminClient をラップする多くの便利なメソッドを提供します。Apache Kafka リスナーの Avro 型を検出して登録します。
ProducerFactory を提供できるトランザクションマネージャー。 バックオフ dueTimestamp ヘッダーを探し、必要に応じてバックオフする
KafkaConsumerBackoffManager インスタンスを呼び出す AcknowledgingConsumerAwareMessageListener 実装。backOff のため、コンシューマーがまだメッセージを消費すべきでない場合にスローされる例外。
KafkaBackOffManagerFactory インスタンスを作成します。Spring の @
KafkaListener アノテーションを処理できる KafkaListenerAnnotationBeanPostProcessor Bean を登録する ImportBeanDefinitionRegistrar クラス。AssertJ カスタム
Conditions. タイムスタンプが将来の場合、指定された dueTimestamp まで
MessageListenerContainer をバックオフするためのインターフェース。 バックオフに使用される状態を提供します。
イベントの基本クラス。
Spring for Apache Kafka 固有の
NestedRuntimeException 実装。KafkaException のログレベル。KafkaException.Level で構成できるクラスのトップレベルの抽象クラス。KafkaListener でアノテーションが付けられたクラス内の Kafka メッセージリスナーのターゲットであるメソッドをマークするアノテーション。Apache Kafka のヘッダーマッパー。
Kafka 固有のメッセージヘッダー定数。
Kafka クライアントに使用できる
AppConfigurationEntrySE を設定するためのプロパティが含まれています。 ログイン構成の制御フラグ値。
指定されたトピックで Kafka メッセージリスナーのターゲットとなるメソッドをマークするアノテーション。
アノテーションのパラメーターに従って、
KafkaListenerContainerFactory によってカバーで作成された Kafka メッセージリスナーコンテナーによって呼び出される、KafkaListener でアノテーションが付けられたメソッドを登録する Bean ポストプロセッサー。 アノテーション属性の各セットを後処理します。
可能な限り遅く
KafkaBootstrapConfiguration をインポートするための最低次数の DeferredImportSelector 実装。Spring によって実装されるオプションのインターフェース Bean が Kafka リスナーエンドポイントの構成方法をカスタマイズすることを望んでいます。
サブパッケージ間で内部共有するための構成定数。
MessageListenerContainer のファクトリ。Kafka リスナーエンドポイントのモデル。
KafkaListenerEndpoint を KafkaListenerEndpointRegistry に登録するためのヘルパー Bean。 登録されたエンドポイントに必要な
MessageListenerContainer インスタンスを作成します。@KafkaListener メソッドが例外をスローしたときに呼び出されるエラーハンドラー。Spring for Apache Kafka リスナーのための観測。
Kafka リスナーキー値のデフォルト
KafkaListenerObservationConvention。 高カーディナリティタグ。
カーディナリティの低いタグ。
Kafka リスナーキー値の
ObservationConvention。 いくつかの
KafkaListener アノテーションを集約するコンテナーアノテーション。Hamcrest
Matcher のユーティリティ。Spring Kafka 要件のための
DefaultMessageHandlerMethodFactory の拡張。 ヘッダーアクセサーは、型固有の方法で特定のヘッダーに簡単にアクセスできるようにします。
ID ヘッダーとタイムスタンプヘッダーを追加するために構成可能なメッセージヘッダーのオーバーロード。
自動パーティション割り当てまたはユーザー構成割り当てをサポートする Java
Consumer を使用するシングルスレッドメッセージリスナーコンテナー。KafkaClientMetrics を管理するための抽象クラス。 このクラスは、NULL Kafka ペイロードを表します。
CompletableFutureSE を返す基本的な Kafka オペレーション契約。KafkaOperations で任意の操作を実行するためのコールバック。Producer で任意の操作を実行するためのコールバック。 生産時の例外。
ConsumerRecords の ReceiverContext。ProducerRecords の SenderContext。 タイムアウト内に応答が受信されない場合の例外。
コンシューマー / プロデューサー / 管理者クリエーターの基本クラス。
Kafka リソースホルダー、Kafka プロデューサーをラップします。
Spring for Apache Kafka 用の
RuntimeHintsRegistrar。Kafka ストリームプロセッサートポロジで
branches を構築するためのメソッドチェーン方法を提供します。StreamsBuilder プロパティのラッパー。KafkaStreams を直接構成するために使用できるコールバックインターフェース。KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME という名前の StreamsConfig がアプリケーションコンテキストに存在する場合、StreamsBuilderFactoryBean を登録する @Configuration クラス。StreamsBuilder や Topology などのインフラストラクチャコンポーネント用のカスタマイザ。Kafka ストリーム内のインタラクティブクエリストアを囲むラッパー API を提供します。
KafkaStreams の KafkaStreamsMetrics を作成します。 高レベルの操作を実行するためのテンプレート。
Spring for Apache Kafka
KafkaTemplate の観測。Kafka テンプレートキー値のデフォルト
KafkaTemplateObservationConvention。 カーディナリティの低いタグ。
Kafka テンプレートキー値の
ObservationConvention。Kafka テストユーティリティ。
単一の Kafka
ProducerFactory の PlatformTransactionManager 実装。 ユーティリティメソッド。
Kotlin
suspend 機能をサポートするための InvocableHandlerMethod 拡張。 付属の
ConcurrentKafkaListenerContainerFactory を装飾して、DefaultErrorHandler と DeadLetterPublishingRecovererFactory によって作成された DeadLetterPublishingRecoverer を追加します。RetryTopicConfiguration によって使用される ConcurrentKafkaListenerContainerFactory を解決します。 コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。
アイドルイベントを発行するように構成されている場合、コンテナーがアイドル状態でなくなったときに発行されるイベント。
コンテナーがアイドル状態になるように構成されている場合に、コンテナーパーティションがアイドル状態になったときに発生するイベント。
アイドルイベントを発行するように構成されている場合、パーティションがアイドルでなくなったときに発行されるイベント。
MessageListenerContainer の一時停止と再開のためのサービス。 リスナーコンテナーのレジストリ。
リスナー固有の
KafkaException 拡張。KafkaListener に関連付けられたメタデータ。 リスナーの型を定義します。
リスナーユーティリティ。
テストメソッドの実行中にクラスのセットのロガーレベルを変更する JUnit メソッド @ ルール。
成功した場合は DEBUG レベルで、失敗した場合は ERROR のコミット結果をログに記録します。
メッセージの送信時にスローされた例外をログに記録する
ProducerListener。 構成可能なログレベルをサポートする commons-logging Log のラッパー。
ログレベル。
これでアノテーションが付けられたテストクラスは、テスト間でログレベルを変更します。
各テストの前後にログレベルを調整および元に戻す JUnit 条件。
手動 ack をサポートする
KafkaListenerErrorHandler。 パラメーター化された (ジェネリクス) 型を処理できる
MappingJackson2MessageConverter のサブクラス。 メッセージコンバーターのトップレベルのインターフェース。
個々の受信 Kafka メッセージを処理するためのリスナー。
メッセージリスナコンテナーを表すフレームワークによって使用される内部抽象化。
個々のメッセージを受信するメッセージリスナーのメッセージング
MessageConverter 実装。Message のペイロードを抽出するために必要なインフラストラクチャを提供する抽象 MessageListener アダプター。 応答式評価のルートオブジェクト。
このエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供する
KafkaListenerEndpoint。KafkaClientMetrics を管理するコンシューマーファクトリリスナー。 クラスパスで使用可能な場合の micrometer タイマーのラッパー。
KafkaClientMetrics を管理するプロデューサーファクトリリスナー。 テストでの
MockConsumer の使用をサポートします。 テストでの
MockProducer の使用をサポートします。KafkaHandler に基づくいくつかの POJO メソッドの MethodKafkaListenerEndpoint 拡張。 コンシューマーが投票に応答していないときに発行されるイベント。kafka-clients の初期バージョンでは、これはブローカーがダウンしていることを示している可能性があります。
プロデューサーが利用できない場合の例外。
OffsetAndMetadata のプロバイダー。Kafka から受信した
StringSE 表現からエンティティを逆直列化するための汎用 Deserializer (別名、解析)。KafkaListener にパーティション / 初期オフセット情報を追加するために使用されます。Producer インスタンスを生成する戦略。 プロデューサーが追加または削除されるたびに呼び出されます。
Spring ベースの Kafka
DefaultKafkaProducerFactory を管理するためのヘルパークラス、特に特定の ProducerFactory のトランザクション Kafka リソースを取得するためのクラス。 送信 Kafka メッセージを処理するためのリスナー。
新しく作成されたプロデューサーに対して後処理を実行するために、プロデューサーファクトリによって呼び出されます。
Spring Data
ProjectionFactory を使用して受信メッセージを射影インターフェースにバインドする MessageConverter 実装。 リアクティブ kafka コンシューマー操作の実装。
リアクティブ kafka プロデューサー操作の実装。
このインターフェースの実装は、メッセージリスナーに配信されようとしているレコードを配信する代わりに破棄する必要があることを通知できます。
リスナーを呼び出す前後にリスナーコンテナーによって呼び出される
ConsumerRecord のインターセプター。Kafka 固有の
Message コンバーター戦略。 構成可能な
HandlerAdapter を呼び出す MessageListener アダプター。リスナーが個々のメッセージを受信するようにファクトリが構成されている場合に使用されます。ConsumerRecordRecoverer を呼び出す DeserializationExceptionHandler。 レコードをスキップする必要があるかどうかを判断するために呼び出されます。
応答メッセージに設定するヘッダーがある場合は、それを構成するための戦略。
リクエスト / 応答操作。
リクエスト / 応答セマンティクスを実装する KafkaTemplate。
リクエスト / 応答用の
CompletableFutureSE。Message 応答の聞き取り可能な未来。 特定のペイロード型で応答する
Message のリッスン可能な未来。KafkaListener アノテーション付きリスナーの再試行および dlt トピックを作成するためのアノテーション。 提供された
RetryableTopic アノテーションを処理して、RetryTopicConfiguration を返します。 一時的なエラーが発生した場合にデシリアライゼーションを再試行するために、デリゲートと
RetryOperations で構成されたデシリアライザー。 再試行アクティビティのリスナー。
ノンブロッキングトピックベースの遅延再試行機能の Bean 名。
RetryTopicConfigurationSupport で使用されるコンポーネントインスタンスを提供します。 再試行可能なトピック用に提供された構成が含まれています。
RetryTopicConfiguration インスタンスを作成するためのビルダークラス。RetryableTopic アノテーションから、またはアノテーションが利用できない場合は Bean コンテナーからインスタンスを作成して、RetryTopicConfiguration のインスタンスを提供しようとします。 これは、ノンブロッキングのトピックベースの遅延再試行機能の背後にある構成を提供するメインクラスです。
ノンブロッキングで使用されるブロッキング再試行を構成します。
トピックの再試行機能によってインスタンス化されたコンポーネントのカスタマイザーを構成します。
メインエンドポイントと提供された構成に基づいてメイン、再試行、DLT トピックを構成し、順序の保証を犠牲にしてノンブロッキング方式で分散再試行 /DLT パターンを実現します。
RetryTopic 機能の定数。
転送されたメッセージで使用されるヘッダーが含まれます。
再試行およびデッドレタートピックに関連する命名を処理します。
再試行トピックのためにパーティションが一時停止されたときにコンテナーの再開をスケジュールするために使用する
TaskScheduler のラッパークラス。 トピック名に基づいてメッセージをルーティングする
KafkaTemplate。 複数の連続した再試行のバックオフ間隔が同じ場合のトピック再利用の戦略。
ユーティリティを探します。
送信後の
CompletableFutureSE の結果。 直列化のためのユーティリティ。
ヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは変更されずに byte[] としてマップされます。
KafkaStreams が追加または削除されるたびに呼び出されます。StreamsBuilderFactoryBean のコンフィギュレーター。JSON メッセージコンバーター - 出力の文字列、入力の文字列、バイト、byte[]。
文字列をサフィックスするユーティリティクラス。
各名前に接尾辞を追加する再試行およびデッドレターの命名処理。
Consumer が使用可能な場合に、スレッドにバインドされたリソースを管理するための一般的なインターフェース。 スローされたときのタイムスタンプを記録する
KafkaException。ToStringSerializer および ParseStringDeserializer に委譲する Serde。NewTopic のビルダー。 この
NewTopic が再試行可能なトピック用であることを示すマーカー。通常の NewTopic が存在する場合、管理者はこれらを無視します。 トピック / パーティション情報を
KafkaListener に追加するために使用されます。 トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。
「特別な」シークの列挙。
RetryTopic 機能の定数。
エンティティの直列化された表現を取得するために
Object.toString() に依存する汎用 Serializer。 トランザクションプロデューサーサフィックスを管理するための戦略。
ChainedTransactionManagerjavadoc を参照してください。