クラス AbstractKafkaHeaderMapper

メソッドの詳細

• 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

  関連事項:

  • setRawMappedHeaders(Map)

• getCharset

  protected CharsetSE getCharset()

• setCharset

  public void setCharset(CharsetSE charset)

  文字列値のヘッダーを byte[] との間でマッピングするときに使用する文字セットを設定します。デフォルトの UTF-8。

  パラメーター:

  charset - 文字セット。

  導入:

  2.2.5

  関連事項:

  • setRawMappedHeaders(Map)

• 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

  関連事項:

  • setCharset(Charset)
  • setMapAllStringsOut(boolean)

• addRawMappedHeader

  public void addRawMappedHeader(StringSE name, boolean toString)

  生のマップされたヘッダーを追加します。

  パラメーター:

  name - ヘッダー名。

  toString - true の場合、受信で文字列に変換します。

  導入:

  2.7.1

  関連事項:

  • setRawMappedHeaders(Map)

• setMultiValueHeaderPatterns

  public void setMultiValueHeaderPatterns(StringSE... patterns)

  同じキーにある複数の値ヘッダーを一致させるためのパターンを追加します。

  パラメーター:

  patterns - ヘッダーのパターン。

  導入:

  4.0

• 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

• doesMatchMultiValueHeader

  protected boolean doesMatchMultiValueHeader(StringSE headerName)

  指定されたヘッダー名を複数の値にマッピングするかどうかを判定します。このメソッドはまず、マッピング結果がすでにキャッシュされているかどうかを確認します。キャッシュされた結果が存在する場合は、すぐに返されます。存在しない場合は、doesMatchInternal(headerName) を呼び出して結果を計算し、キャッシュしてから返します。

  パラメーター:

  headerName - ヘッダー名。

  戻り値:

  同じキーに複数の値がある場合は True になります。

  導入:

  4.0

• fromUserHeader

  protected void fromUserHeader(StringSE headerName, org.apache.kafka.common.header.Header header, MapSE<StringSE,ObjectSE> headers)

  DefaultKafkaHeaderMapper 内の予約されていないヘッダーを処理します。

  パラメーター:

  headerName - ヘッダー名。

  header - ヘッダーインスタンス。

  headers - ターゲットヘッダー。

  導入:

  4.0

• headerValueToAddIn

  protected @Nullable ObjectSE headerValueToAddIn(@Nullable org.apache.kafka.common.header.Header header)

  構成されている場合、ヘッダー値を文字列にマップする必要があるかどうかを確認します。

  パラメーター:

  header - ヘッダー。

  戻り値:

  追加する値。