クラス DelegatingByTypeSerializer
java.lang.ObjectSE
org.springframework.kafka.support.serializer.DelegatingByTypeSerializer
- 実装されたすべてのインターフェース:
CloseableSE
、AutoCloseableSE
、org.apache.kafka.common.serialization.Serializer<ObjectSE>
public class DelegatingByTypeSerializer
extends ObjectSE
implements org.apache.kafka.common.serialization.Serializer<ObjectSE>
型に基づいてシリアライザーに委譲します。
- 導入:
- 2.7.9
- 作成者:
- Gary Russell, Artem Bilan, Wang Zhiyang
コンストラクターのサマリー
コンストラクターコンストラクター説明DelegatingByTypeSerializer
(MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates) デリゲートのマップを使用してインスタンスを構築します。キーは完全に一致しました。DelegatingByTypeSerializer
(MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates, boolean assignable) デリゲートのマップを使用してインスタンスを構築します。割り当て可能な引数に応じて、キーが完全に一致するか、ターゲットオブジェクトがキーに割り当て可能かどうか。メソッドのサマリー
修飾子と型メソッド説明void
protected <T> org.apache.kafka.common.serialization.Serializer<T>
findDelegate
(T data, MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates) データ型のシリアライザーを決定します。protected boolean
findDelegate(Object, Map)
が完全一致ではなく、キーへの割り当て可能性を考慮する必要がある場合は、true を返します。byte[]
byte[]
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.apache.kafka.common.serialization.Serializer から継承されたメソッド
close
コンストラクターの詳細
DelegatingByTypeSerializer
public DelegatingByTypeSerializer(MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates) デリゲートのマップを使用してインスタンスを構築します。キーは完全に一致しました。- パラメーター:
delegates
- 代表団。
DelegatingByTypeSerializer
public DelegatingByTypeSerializer(MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates, boolean assignable) デリゲートのマップを使用してインスタンスを構築します。割り当て可能な引数に応じて、キーが正確に一致したか、ターゲットオブジェクトがキーに割り当て可能かどうか。割り当て可能な場合、エントリは自然なエントリ順でチェックされるため、LinkedHashMap
SE などの順序付きマップが推奨されます。- パラメーター:
delegates
- 代表団。assignable
- ターゲットがキーに割り当て可能かどうか。- 導入:
- 2.8.3
メソッドの詳細
isAssignable
protected boolean isAssignable()findDelegate(Object, Map)
が完全一致ではなく、キーへの割り当て可能性を考慮する必要がある場合は、true を返します。- 戻り値:
- 割り当て可能な場合は true。
- 導入:
- 2.8.3
configure
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Serializer<ObjectSE>
のconfigure
serialize
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Serializer<ObjectSE>
のserialize
serialize
public byte[] serialize(StringSE topic, org.apache.kafka.common.header.Headers headers, ObjectSE data) - 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Serializer<ObjectSE>
のserialize
findDelegate
protected <T> org.apache.kafka.common.serialization.Serializer<T> findDelegate(T data, MapSE<ClassSE<?>, org.apache.kafka.common.serialization.Serializer<?>> delegates) データ型のシリアライザーを決定します。- 型パラメーター:
T
- データ型- パラメーター:
data
- データ。delegates
- 利用可能な代表者。- 戻り値:
- 代表者。
- 例外:
org.apache.kafka.common.errors.SerializationException
- 一致するものがない場合。- 導入:
- 2.8.3