クラス 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
(org.apache.kafka.common.serialization.Deserializer<T> delegate, org.springframework.retry.RetryOperations retryOperations) メソッドのサマリー
修飾子と型メソッド説明void
close()
void
deserialize
(StringSE topic, byte[] data) deserialize
(StringSE topic, org.apache.kafka.common.header.Headers headers, byte[] data) deserialize
(StringSE topic, org.apache.kafka.common.header.Headers headers, ByteBufferSE data) void
setRecoveryCallback
(org.springframework.retry.RecoveryCallback<T> recoveryCallback) 再試行回数が尽きたときに実行するリカバリコールバックを設定します。
コンストラクターの詳細
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
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のconfigure
deserialize
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のdeserialize
deserialize
- 次で指定:
- インターフェース
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