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

クラス DelegatingByTopicSerializer

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

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

    • DelegatingByTopicSerializer

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

    • DelegatingByTopicSerializer

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

  • メソッドの詳細

    • configure

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

    • configureDelegate

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

    • isInstance

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

    • 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