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