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

クラス DelegatingSerializer

java.lang.ObjectSE
org.springframework.kafka.support.serializer.DelegatingSerializer
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.common.serialization.Serializer<ObjectSE>
public class DelegatingSerializer extends ObjectSE implements org.apache.kafka.common.serialization.Serializer<ObjectSE>
直列化セレクターヘッダーに基づいて他のシリアライザーに委譲する Serializer。ヘッダーが欠落していて、その型が Serdes でサポートされている場合は、そのシリアライザー型に委譲します。
導入:
2.3
作成者:
Gary Russell

  • フィールドの詳細

    • VALUE_SERIALIZATION_SELECTOR

      public static final StringSE VALUE_SERIALIZATION_SELECTOR
      値の直列化セレクターを含むヘッダーの名前。
      関連事項:

    • KEY_SERIALIZATION_SELECTOR

      public static final StringSE KEY_SERIALIZATION_SELECTOR
      キーの直列化セレクターを含むヘッダーの名前。
      関連事項:

    • VALUE_SERIALIZATION_SELECTOR_CONFIG

      public static final StringSE VALUE_SERIALIZATION_SELECTOR_CONFIG
      selector:class,... 形式の値の直列化セレクターマップを含む構成プロパティの名前。
      関連事項:

    • KEY_SERIALIZATION_SELECTOR_CONFIG

      public static final StringSE KEY_SERIALIZATION_SELECTOR_CONFIG
      selector:class,... 形式のキーの直列化セレクターマップを含む構成プロパティの名前。
      関連事項:

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

    • DelegatingSerializer

      public DelegatingSerializer()
      プロデューサープロパティ VALUE_SERIALIZATION_SELECTOR_CONFIG および KEY_SERIALIZATION_SELECTOR_CONFIG を使用して configure(Map, boolean) で構成されるインスタンスを作成します。

    • DelegatingSerializer

      public DelegatingSerializer(MapSE<StringSE,org.apache.kafka.common.serialization.Serializer<?>> delegates)
      提供されたセレクターのマッピングを使用してインスタンスを構築し、シリアライザーを委譲します。セレクターは、KEY_SERIALIZATION_SELECTOR および / または VALUE_SERIALIZATION_SELECTOR ヘッダーで指定する必要があります。Serdes でサポートされている標準のシリアライザーを構成する必要はありません。
      パラメーター:
      delegates - 代表者の地図。

  • メソッドの詳細

    • configure

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

    • createDelegates

      protected static MapSE<StringSE,org.apache.kafka.common.serialization.Serializer<?>> createDelegates(StringSE mappings, MapSE<StringSE,?> configs, boolean isKey)

    • createInstanceAndConfigure

      protected static void createInstanceAndConfigure(MapSE<StringSE,?> configs, boolean isKey, MapSE<StringSE,org.apache.kafka.common.serialization.Serializer<?>> delegateMap, StringSE selector, StringSE className)

    • instantiateAndConfigure

      protected static void instantiateAndConfigure(MapSE<StringSE,?> configs, boolean isKey, MapSE<StringSE,org.apache.kafka.common.serialization.Serializer<?>> delegateMap, StringSE selector, ClassSE<?> clazz)

    • addDelegate

      public void addDelegate(StringSE selector, org.apache.kafka.common.serialization.Serializer<?> serializer)

    • removeDelegate

      @Nullable public org.apache.kafka.common.serialization.Serializer<?> removeDelegate(StringSE selector)

    • 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 

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Serializer<ObjectSE> の close