パッケージ 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, Stephane Nicoll

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

    • RetryingDeserializer

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

  • 方法の詳細

    • setRecoveryCallback

      public void setRecoveryCallback(FunctionSE<RetryException,T> recoveryCallback)
      再試行回数が尽きたときに実行するリカバリコールバックを設定します。
      パラメーター:
      recoveryCallback - 回復コールバック
      導入:
      4.0
      関連事項:

    • configure

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

    • deserialize

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

    • deserialize

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

    • deserialize

      public @Nullable 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