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

クラス RetryingDeserializer<T>

java.lang.ObjectSE
org.springframework.kafka.support.serializer.RetryingDeserializer<T>
型パラメーター:
T - デシリアライズする型。
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.common.serialization.Deserializer<T>
public class RetryingDeserializer<T> extends ObjectSE implements org.apache.kafka.common.serialization.Deserializer<T>
一時的なエラーが発生した場合にデシリアライゼーションを再試行するために、デリゲートと RetryOperations で構成されたデシリアライザー。
導入:
2.3
作成者:
Gary Russell, Wang Zhiyang, Soby Chacko

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

    • RetryingDeserializer

      public RetryingDeserializer(org.apache.kafka.common.serialization.Deserializer<T> delegate, org.springframework.retry.RetryOperations retryOperations)

  • メソッドの詳細

    • setRecoveryCallback

      public void setRecoveryCallback(@Nullable org.springframework.retry.RecoveryCallback<T> recoveryCallback)
      再試行回数が尽きたときに実行するリカバリコールバックを設定します。
      パラメーター:
      recoveryCallback - RecoveryCallback を実行する
      導入:
      3.1.2

    • configure

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

    • 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 

    • deserialize

      public T deserialize(StringSE topic, org.apache.kafka.common.header.Headers headers, ByteBufferSE 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