パッケージの使用
org.springframework.kafka.support
org.springframework.kafka.support を使用するパッケージ
パッケージ
説明
kafka アノテーションのパッケージ
kafka 構成のパッケージ
kafka コアコンポーネントのパッケージ
kafka リスナーのためのパッケージ
リスナーを適応させるためのクラスを提供します。
リクエスト / 応答セマンティクスのクラスを提供します。
再試行可能なトピック処理用のパッケージ。
kafka サポート用パッケージ
kafka コンバーター用パッケージ
- クラス説明送信 Kafka メッセージを処理するためのリスナー。送信後の
CompletableFutureSE の結果。トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。 - クラス説明
ConsumerRecordの処理を承認するためのハンドル。ネストされた原因内の一致する例外を識別するためのサポートを備えた、構成可能な例外マッチャー。ログレベル。送信後のCompletableFutureSE の結果。共有グループを使用するときにレコードの配信を確認するためのハンドル。トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。 - クラス説明
ConsumerRecordの処理を承認するためのハンドル。Apache Kafka のヘッダーマッパー。このクラスは、NULL Kafka ペイロードを表します。共有グループを使用するときにレコードの配信を確認するためのハンドル。 - クラス説明エンドポイントを再試行するためのハンドラーメソッド。ネストされた原因内の一致する例外を識別するためのサポートを備えた、構成可能な例外マッチャー。
- クラス説明Kafka ヘッダーマッパーのベース。ヘッダーのマッチャー。許可 / 拒否コレクションとその述語を管理するためのクラス。非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。エンドポイントを再試行するためのハンドラーメソッド。ネストされた原因内の一致する例外を識別するためのサポートを備えた、構成可能な例外マッチャー。
ExceptionMatcherを構成するための Fluent API。一部の Java 反復コードを単純化するための連鎖ユーティリティメソッド。Apache Kafka のデフォルトのヘッダーマッパー。Apache Kafka のヘッダーマッパー。ヘッダーアクセサーは、型固有の方法で特定のヘッダーに簡単にアクセスできるようにします。このクラスは、NULL Kafka ペイロードを表します。Kafka ストリームプロセッサートポロジでbranchesを構築するためのメソッドチェーン方法を提供します。ログレベル。送信 Kafka メッセージを処理するためのリスナー。ヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは変更されずに byte[] としてマップされます。「特別な」シークの列挙。
JsonKafkaHeaderMapperが優先されます。