パッケージ org.springframework.kafka.support
@NullMarked パッケージ org.springframework.kafka.support
kafka サポート用パッケージ
- クラス説明Kafka ヘッダーマッパーのベース。ヘッダーのマッチャー。ヘッダーのセットに一致しないマッチャー。指定されたヘッダーが指定された単純なパターンに一致する場合に一致するパターンベースのヘッダーマッチャー。
ConsumerRecordの処理を承認するためのハンドル。許可 / 拒否コレクションとその述語を管理するためのクラス。インターセプターのコレクションに委譲するProducerInterceptor。リスナーのコレクションに委譲するProducerListener。非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。信頼できない型が原因でデコードできなかったヘッダーを表します。エンドポイントを再試行するためのハンドラーメソッド。エンドポイントを再試行するためのハンドラーマルチメソッド。ネストされた原因内の一致する例外を識別するためのサポートを備えた、構成可能な例外マッチャー。ExceptionMatcherを構成するための Fluent API。最大経過時間ではなく最大再試行回数を指定できるExponentialBackOffのサブクラス。JacksonObjectMapperインスタンスのユーティリティ。非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。MimeTypeJacksonModuleを推奨する 4.0 以降。Jackson JSON プロセッサーがクラスパスに存在するかどうかを確認するユーティリティ。非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。4.0 以降、JacksonMapperUtilsAPI が優先されます。一部の Java 反復コードを単純化するための連鎖ユーティリティメソッド。Apache Kafka のデフォルトのヘッダーマッパー。信頼できない型が原因でデコードできなかったヘッダーを表します。Apache Kafka のヘッダーマッパー。Kafka 固有のメッセージヘッダー定数。ヘッダーアクセサーは、型固有の方法で特定のヘッダーに簡単にアクセスできるようにします。このクラスは、NULL Kafka ペイロードを表します。KafkaStreamBrancher<K,V> Kafka ストリームプロセッサートポロジでbranchesを構築するためのメソッドチェーン方法を提供します。ユーティリティメソッド。メッセージの送信時にスローされた例外をログに記録するProducerListener。構成可能なログレベルをサポートする commons-logging Log のラッパー。ログレベル。MimeTypeシリアライゼーション用のSimpleModule拡張。ProducerListener<K,V> 送信 Kafka メッセージを処理するためのリスナー。SendResult<K,V> 送信後のCompletableFutureSE の結果。共有グループを使用するときにレコードの配信を確認するためのハンドル。ヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは変更されずに byte[] としてマップされます。文字列をサフィックスするユーティリティクラス。このNewTopicが再試行可能なトピック用であることを示すマーカー。通常のNewTopicが存在する場合、管理者はこれらを無視します。トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。「特別な」シークの列挙。
JsonKafkaHeaderMapperが優先されます。