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

クラス ErrorHandlingDeserializer<T>

java.lang.ObjectSE
org.springframework.kafka.support.serializer.ErrorHandlingDeserializer<T>
型パラメーター:
T - メッセージを表すエンティティのクラス
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.common.serialization.Deserializer<T>
public class ErrorHandlingDeserializer<T> extends ObjectSE implements org.apache.kafka.common.serialization.Deserializer<T>
例外をキャッチするデリゲートキー / 値デシリアライザは、直列化された java オブジェクトとしてヘッダーに返します。
導入:
2.2
作成者:
Gary Russell, Artem Bilan, Victor Perez Rey

  • フィールドの詳細

    • KEY_FUNCTION

      public static final StringSE KEY_FUNCTION
      デシリアライズが失敗したときの T のサプライヤー。
      関連事項:

    • VALUE_FUNCTION

      public static final StringSE VALUE_FUNCTION
      デシリアライズが失敗したときの T のサプライヤー。
      関連事項:

    • KEY_DESERIALIZER_CLASS

      public static final StringSE KEY_DESERIALIZER_CLASS
      デリゲートキーデシリアライザーのプロパティ名。
      関連事項:

    • VALUE_DESERIALIZER_CLASS

      public static final StringSE VALUE_DESERIALIZER_CLASS
      デリゲート値デシリアライザーのプロパティ名。
      関連事項:

    • VALIDATOR_CLASS

      public static final StringSE VALIDATOR_CLASS
      バリデーターのプロパティ名。
      関連事項:

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

    • ErrorHandlingDeserializer

      public ErrorHandlingDeserializer()

    • ErrorHandlingDeserializer

      public ErrorHandlingDeserializer(org.apache.kafka.common.serialization.Deserializer<T> delegate)

  • メソッドの詳細

    • setFailedDeserializationFunction

      public void setFailedDeserializationFunction(FunctionSE<FailedDeserializationInfo,T> failedDeserializationFunction)
      逆直列化が失敗した場合の代替供給メカニズムを提供します。
      パラメーター:
      failedDeserializationFunction - 使用する FunctionSE。
      導入:
      2.2.8

    • isForKey

      public boolean isForKey()

    • setForKey

      public void setForKey(boolean isKey)
      Kafka の外部で構成するときに、このデシリアライザーをキーデシリアライザーとして使用する場合は true に設定します。
      パラメーター:
      isKey - キーデシリアライザーの場合は true、それ以外の場合は false。
      導入:
      2.2.3

    • keyDeserializer

      public ErrorHandlingDeserializer<T> keyDeserializer(boolean isKey)
      Kafka の外部で構成するときに、このデシリアライザーをキーデシリアライザーとして使用する場合は true に設定します。
      パラメーター:
      isKey - キーデシリアライザーの場合は true、それ以外の場合は false。
      戻り値:
      this
      導入:
      2.2.3

    • setValidator

      public void setValidator(Validator validator)
      逆直列化が成功した後にオブジェクトを検証するためのバリデーターを設定します。バリデーターが例外をスローした場合、または検証エラーを含む Errors を返した場合、生データは構成されたエラーハンドラーで使用できます。
      パラメーター:
      validator - 設定するバリデーター
      導入:
      3.1

    • configure

      public void configure(MapSE<StringSE,?> configs, boolean isKey)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> の configure 

    • setupDelegate

      public void setupDelegate(MapSE<StringSE,?> configs, StringSE configKey)

    • deserialize

      public T deserialize(StringSE topic, byte[] data)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> の deserialize 

    • deserialize

      public T deserialize(StringSE topic, org.apache.kafka.common.header.Headers headers, byte[] data)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> の deserialize 

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> の close