クラス SimpleKafkaHeaderMapper

java.lang.ObjectSE
org.springframework.kafka.support.AbstractKafkaHeaderMapper
org.springframework.kafka.support.SimpleKafkaHeaderMapper
実装されているすべてのインターフェース:
KafkaHeaderMapper
public class SimpleKafkaHeaderMapper extends AbstractKafkaHeaderMapper
ヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは byte[] のように変更されずにマップされます。文字列は、バイトとの間でマッピングすることもできます。AbstractKafkaHeaderMapper.setRawMappedHeaders(Map) を参照してください。KafkaHeaders のほとんどのヘッダーは、送信メッセージにマップされていません。例外は、リクエスト / 応答の相関ヘッダーと応答ヘッダーです。
導入:
2.1.3
作成者:
Gary Russell, Sanghyeok An

  • コンストラクターの詳細

    • SimpleKafkaHeaderMapper

      public SimpleKafkaHeaderMapper()
      送信ヘッダーのデフォルトのオブジェクトマッパーとデフォルトのヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。デフォルトのパターンリストは "!id", "!timestamp" and "*" です。さらに、KafkaHeaders のほとんどのヘッダーは、コンシューマー / プロデューサーレコードのデータを表すため、ヘッダーとしてマップされることはありません。

    • SimpleKafkaHeaderMapper

      public SimpleKafkaHeaderMapper(StringSE... patterns)
      デフォルトのオブジェクトマッパーと送信ヘッダー用に提供されたヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。パターンは順番に適用され、最初の一致（正または負）で停止します。パターンの前に "!" を付けると、パターンが無効になります。パターンはデフォルトのパターンを置き換えます。通常、"id" and "timestamp" ヘッダーをマップしないでください。注: KafkaHeaders のほとんどのヘッダーは、コンシューマー / プロデューサーレコードのデータを表すため、ヘッダーとしてマップされることはありません。
      パラメーター:
      patterns - パターン。
      関連事項:

  • メソッドの詳細

    • forInboundOnlyWithMatchers

      public static SimpleKafkaHeaderMapper forInboundOnlyWithMatchers(StringSE... patterns)
      パターンマッチングのみを使用して受信 マッピング用のインスタンスを作成します。
      パラメーター:
      patterns - 一致するパターン。
      戻り値:
      ヘッダーマッパー。
      導入:
      2.8.8

    • fromHeaders

      public void fromHeaders(MessageHeaders headers, org.apache.kafka.common.header.Headers target)
      インターフェースからコピーされた説明: KafkaHeaderMapper
      指定された MessageHeaders から指定されたターゲットヘッダーにマップします。
      パラメーター:
      headers - 抽象化された MessageHeaders。
      target - ネイティブターゲットヘッダー。

    • toHeaders

      public void toHeaders(org.apache.kafka.common.header.Headers source, MapSE<StringSE,ObjectSE> headers)
      インターフェースからコピーされた説明: KafkaHeaderMapper
      指定されたネイティブヘッダーから、最終的な MessageHeaders のヘッダーのマップにマップします。
      パラメーター:
      source - ネイティブヘッダー。
      headers - ターゲットヘッダー。