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

クラス 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
    configure(MapSE<StringSE,?> configs, boolean isKey)
    protected <T> org.apache.kafka.common.serialization.Serializer<T>
    findDelegate(T data, MapSE<ClassSE<?>,org.apache.kafka.common.serialization.Serializer<?>> delegates)
    データ型のシリアライザーを決定します。
    protected boolean
    isAssignable()
    findDelegate(Object, Map) が完全一致ではなく、キーへの割り当て可能性を考慮する必要がある場合は、true を返します。
    byte[]
    serialize(StringSE topic, ObjectSE data)
    byte[]
    serialize(StringSE topic, org.apache.kafka.common.header.Headers headers, ObjectSE data)

    クラス 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)
      デリゲートのマップを使用してインスタンスを構築します。割り当て可能な引数に応じて、キーが正確に一致したか、ターゲットオブジェクトがキーに割り当て可能かどうか。割り当て可能な場合、エントリは自然なエントリ順でチェックされるため、LinkedHashMapSE などの順序付きマップが推奨されます。
      パラメーター:
      delegates - 代表団。
      assignable - ターゲットがキーに割り当て可能かどうか。
      導入:
      2.8.3

  • メソッドの詳細

    • isAssignable

      protected boolean isAssignable()
      findDelegate(Object, Map) が完全一致ではなく、キーへの割り当て可能性を考慮する必要がある場合は、true を返します。
      戻り値:
      割り当て可能な場合は true。
      導入:
      2.8.3

    • configure

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

    • serialize

      public byte[] serialize(StringSE topic, ObjectSE data)
      次で指定:
      インターフェース 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