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

クラス DelegatingByTopicDeserializer

java.lang.ObjectSE
org.springframework.kafka.support.serializer.DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Deserializer<?>>
org.springframework.kafka.support.serializer.DelegatingByTopicDeserializer
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、org.apache.kafka.common.serialization.Deserializer<ObjectSE>
public class DelegatingByTopicDeserializer extends DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Deserializer<?>> implements org.apache.kafka.common.serialization.Deserializer<ObjectSE>
トピック名に基づいて他のデシリアライザーに委譲する Deserializer。
導入:
2.8
作成者:
Gary Russell, Wang Zhiyang

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

    • DelegatingByTopicDeserializer

      public DelegatingByTopicDeserializer()
      コンシューマープロパティを使用して configure(Map, boolean) で構成されるインスタンスを作成します。

    • DelegatingByTopicDeserializer

      public DelegatingByTopicDeserializer(MapSE<PatternSE,org.apache.kafka.common.serialization.Deserializer<?>> delegates, org.apache.kafka.common.serialization.Deserializer<?> defaultDelegate)
      デシリアライザーを委譲するために、提供されたトピック名パターンのマッピングを使用してインスタンスを構築します。
      パラメーター:
      delegates - 代表者の地図。
      defaultDelegate - トピック名が一致しない場合に使用するデフォルト。

  • メソッドの詳細

    • configure

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

    • configureDelegate

      protected org.apache.kafka.common.serialization.Deserializer<?> configureDelegate(MapSE<StringSE,?> configs, boolean isKey, org.apache.kafka.common.serialization.Deserializer<?> delegate)
      クラスからコピーされた説明: DelegatingByTopicSerialization
      デリゲートを構成します。
      次で指定:
      クラス DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Deserializer<?>> の configureDelegate 
      パラメーター:
      configs - 構成。
      isKey - これがキーの場合は true。
      delegate - 代表者。
      戻り値:
      代表者。

    • isInstance

      protected boolean isInstance(ObjectSE delegate)
      クラスからコピーされた説明: DelegatingByTopicSerialization
      このオブジェクトが T のインスタンスである場合、true を返します。
      次で指定:
      クラス DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Deserializer<?>> の isInstance 
      パラメーター:
      delegate - 代表者。
      戻り値:
      T の場合は true。

    • 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