パッケージ org.springframework.kafka.support

クラス AbstractKafkaHeaderMapper

java.lang.ObjectSE
org.springframework.kafka.support.AbstractKafkaHeaderMapper
実装されたすべてのインターフェース:
KafkaHeaderMapper
既知の直属サブクラス
DefaultKafkaHeaderMapper, SimpleKafkaHeaderMapper
public abstract class AbstractKafkaHeaderMapper extends ObjectSE implements KafkaHeaderMapper
Kafka ヘッダーマッパーのベース。
導入:
2.1.3
作成者:
Gary Russell, Artem Bilan

  • フィールドの詳細

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

    • AbstractKafkaHeaderMapper

      public AbstractKafkaHeaderMapper(StringSE... patterns)
      提供されたパターン (送信) とすべてのヘッダー (受信) に一致するマッパーを構築します。送信 マッピングの場合、特定の内部フレームワークヘッダーは決してマッピングされません。
      パラメーター:
      patterns - パターン。

    • AbstractKafkaHeaderMapper

      protected AbstractKafkaHeaderMapper(boolean outbound, StringSE... patterns)
      提供されたパターン (送信) とすべてのヘッダー (受信) に一致するマッパーを構築します。送信 マッピングの場合、特定の内部フレームワークヘッダーは決してマッピングされません。
      パラメーター:
      outbound - 送信 マッパーの場合は true。
      patterns - パターン。

  • メソッドの詳細

    • addMatchers

      protected final void addMatchers(AbstractKafkaHeaderMapper.HeaderMatcher... matchersToAdd)
      サブクラスは、これを呼び出してカスタム AbstractKafkaHeaderMapper.HeaderMatcher を追加できます。
      パラメーター:
      matchersToAdd - 追加するマッチャー。
      導入:
      2.3

    • setMapAllStringsOut

      public void setMapAllStringsOut(boolean mapAllStringsOut)
      すべての String 値の送信 ヘッダーを byte[] にマップするには、true に設定します。受信用に String にマップするには、rawMappedHeaders マップにエントリが必要です。
      パラメーター:
      mapAllStringsOut - すべての文字列をマップする場合は true。
      導入:
      2.2.5
      関連事項:

    • getCharset

      protected CharsetSE getCharset()

    • setCharset

      public void setCharset(CharsetSE charset)
      文字列値のヘッダーを byte[] との間でマッピングするときに使用する文字セットを設定します。デフォルトの UTF-8。
      パラメーター:
      charset - 文字セット。
      導入:
      2.2.5
      関連事項:

    • setRawMappedHeaders

      public void setRawMappedHeaders(MapSE<StringSE,BooleanSE> rawMappedHeaders)
      ヘッダーに対して変換を行わないように設定してください (送信用の String から byte[] を除く)。一致する受信ヘッダーは、マップ値内の対応するブール値が true でない限り、byte[] としてマップされます。true の場合は、文字列としてマップされます。デフォルトでマップされるヘッダーは、kafka_listenerInfo、b3、traceparent、X-B3-TraceId、X-B3-SpanId、X-B3-Sampled、X-B3-Flags です。
      パラメーター:
      rawMappedHeaders - 変換しないヘッダー名と
      導入:
      2.2.5
      関連事項:

    • addRawMappedHeader

      public void addRawMappedHeader(StringSE name, boolean toString)
      生のマップされたヘッダーを追加します。
      パラメーター:
      name - ヘッダー名。
      toString - true の場合、受信で文字列に変換します。
      導入:
      2.7.1
      関連事項:

    • matches

      protected boolean matches(StringSE header, ObjectSE value)

    • matches

      protected boolean matches(StringSE header)

    • matchesForInbound

      protected boolean matchesForInbound(StringSE header)
      受信 マッパーとして構成されている場合、受信 マッピングのヘッダー名を照合します。
      パラメーター:
      header - ヘッダー名。
      戻り値:
      マップできる場合は true。
      導入:
      2.8.8

    • headerValueToAddOut

      protected ObjectSE headerValueToAddOut(StringSE key, ObjectSE value)
      値が文字列であるかどうかを確認し、構成されている場合は byte[] に変換します。
      パラメーター:
      key - ヘッダー名。
      value - ヘッダー値。
      戻り値:
      追加する値。
      導入:
      2.2.5

    • headerValueToAddIn

      protected ObjectSE headerValueToAddIn(org.apache.kafka.common.header.Header header)
      構成されている場合、ヘッダー値を文字列にマップする必要があるかどうかを確認します。
      パラメーター:
      header - ヘッダー。
      戻り値:
      追加する値。