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

クラス DeserializationException

java.lang.ObjectSE
java.lang.ThrowableSE
java.lang.ExceptionSE
java.lang.RuntimeExceptionSE
org.springframework.core.NestedRuntimeException
org.springframework.kafka.KafkaException
org.springframework.kafka.support.serializer.DeserializationException
実装されたすべてのインターフェース:
SerializableSE
public class DeserializationException extends KafkaException
逆直列化の失敗が発生したときに、コンシューマーレコードの値またはキーで例外が返されました。
導入:
2.2
作成者:
Gary Russell, Artem Bilan
関連事項:

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

    • DeserializationException

      public DeserializationException(StringSE message, byte[] data, boolean isKey, ThrowableSE cause)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      message - メッセージ。
      data - データ（値またはキー）。
      isKey - キーの逆直列化中に例外が発生した場合は true。
      cause - 原因。

  • メソッドの詳細

    • getHeaders

      @Nullable public org.apache.kafka.common.header.Headers getHeaders()
      ヘッダーを取得します。
      戻り値:
      ヘッダー。

    • setHeaders

      public void setHeaders(@Nullable org.apache.kafka.common.header.Headers headers)
      ヘッダーを設定します。
      パラメーター:
      headers - ヘッダー。

    • getData

      public byte[] getData()
      デシリアライズに失敗したデータ（値またはキー）を取得します。
      戻り値:
      データ。

    • isKey

      public boolean isKey()
      キーの逆直列化が失敗した場合は True、それ以外の場合は値の逆直列化が失敗しました。
      戻り値:
      キーの場合は true です。