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

クラス DelegatingDeserializer

java.lang.ObjectSE
org.springframework.kafka.support.serializer.DelegatingDeserializer
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.common.serialization.Deserializer<ObjectSE>
public class DelegatingDeserializer extends ObjectSE implements org.apache.kafka.common.serialization.Deserializer<ObjectSE>
直列化セレクターヘッダーに基づいて他のデシリアライザーに委譲する Deserializer。Serdes でサポートされている標準のデシリアライザーを構成する必要はありません。
導入:
2.3
作成者:
Gary Russell, Wang Zhiyang

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

  • メソッドの詳細

    • configure

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

    • createDelegates

      protected static MapSE<StringSE,org.apache.kafka.common.serialization.Deserializer<?>> 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.Deserializer<?>> delegateMap, StringSE selector, StringSE className)

    • instantiateAndConfigure

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

    • addDelegate

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

    • removeDelegate

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

    • deserialize

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

    • deserialize

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

    • deserialize

      public ObjectSE deserialize(StringSE topic, org.apache.kafka.common.header.Headers headers, ByteBufferSE data)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<ObjectSE> の deserialize 

    • close

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