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

クラス SerializationUtils

java.lang.ObjectSE
org.springframework.kafka.support.serializer.SerializationUtils
public final class SerializationUtils extends ObjectSE
直列化のためのユーティリティ。
導入:
2.5
作成者:
Gary Russell

  • フィールドの詳細

    • DESERIALIZER_EXCEPTION_HEADER_PREFIX

      public static final StringSE DESERIALIZER_EXCEPTION_HEADER_PREFIX
      デシリアライズ例外のヘッダー名。
      導入:
      2.8
      関連事項:

    • KEY_DESERIALIZER_EXCEPTION_HEADER

      public static final StringSE KEY_DESERIALIZER_EXCEPTION_HEADER
      デシリアライズ例外のヘッダー名。
      導入:
      2.8
      関連事項:

    • VALUE_DESERIALIZER_EXCEPTION_HEADER

      public static final StringSE VALUE_DESERIALIZER_EXCEPTION_HEADER
      デシリアライズ例外のヘッダー名。
      導入:
      2.8
      関連事項:

  • メソッドの詳細

    • propertyToMethodInvokingFunction

      public static <P, T> BiFunctionSE<P,org.apache.kafka.common.header.Headers,T> propertyToMethodInvokingFunction(StringSE methodProperty, ClassSE<P> payloadType, ClassLoaderSE classLoader)
      プロパティ値 (FQCN.methodName) を、ペイロードとヘッダーを受け取り、何らかの値を返す BiFunctionSE に変換します。メソッドにはパラメーター (P, Headers) または (P) があり、静的として宣言されている必要があります。
      型パラメーター:
      P - BiFunctionSE の最初のパラメーター型。
      T - BiFunctionSE 戻り型。
      パラメーター:
      methodProperty - メソッド名プロパティ。
      payloadType - BiFunctionSE の最初のパラメーター型。
      classLoader - クラスローダー。
      戻り値:
      関数。

    • deserializationException

      public static void deserializationException(org.apache.kafka.common.header.Headers headers, byte[] data, ExceptionSE ex, boolean isForKeyArg)
      レコードヘッダーに直列化された DeserializationException を入力します。
      パラメーター:
      headers - ヘッダー。
      data - データ。
      ex - 例外。
      isForKeyArg - これがキーの逆直列化の問題である場合は true、それ以外の場合は値。
      導入:
      2.8

    • getExceptionFromHeader

      @Nullable public static DeserializationException getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, StringSE headerName, LogAccessor logger)
      存在する場合は、指定されたヘッダー名から DeserializationException を抽出します。
      パラメーター:
      record - コンシューマー記録。
      headerName - ヘッダー名。
      logger - エラーをログに記録するためのロガー。
      戻り値:
      例外または null。
      導入:
      2.9.11

    • byteArrayToDeserializationException

      @Nullable public static DeserializationException byteArrayToDeserializationException(LogAccessor logger, org.apache.kafka.common.header.Header header)
      直列化された DeserializationException を含むバイト配列を DeserializationException に変換します。
      パラメーター:
      logger - エラーをログに記録するためのログアクセサー。
      header - ヘッダー。
      戻り値:
      逆直列化が失敗した場合は例外または null。
      導入:
      2.9.11