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

クラス DelegatingByTopicSerialization<T extends CloseableSE>

java.lang.ObjectSE
org.springframework.kafka.support.serializer.DelegatingByTopicSerialization<T>
型パラメーター:
T - 型。
実装されたすべてのインターフェース:
CloseableSE, AutoCloseableSE
既知の直属サブクラス
DelegatingByTopicDeserializer, DelegatingByTopicSerializer
public abstract class DelegatingByTopicSerialization<T extends CloseableSE> extends ObjectSE implements CloseableSE
トピックの直列化によって委譲するための共通コードを持つ基本クラス。
導入:
2.8
作成者:
Gary Russell, Wang Zhiyang

  • フィールドの詳細

    • VALUE_SERIALIZATION_TOPIC_CONFIG

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

    • KEY_SERIALIZATION_TOPIC_CONFIG

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

    • VALUE_SERIALIZATION_TOPIC_DEFAULT

      public static final StringSE VALUE_SERIALIZATION_TOPIC_DEFAULT
      トピック名が一致しない場合のキーのデフォルトのデリゲートの名前。
      関連事項:

    • KEY_SERIALIZATION_TOPIC_DEFAULT

      public static final StringSE KEY_SERIALIZATION_TOPIC_DEFAULT
      トピック名が一致しない場合のキーのデフォルトのデリゲートの名前。
      関連事項:

    • CASE_SENSITIVE

      public static final StringSE CASE_SENSITIVE
      false に設定すると、トピックパターンマッチングで大文字と小文字が区別されなくなります。
      関連事項:

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

    • DelegatingByTopicSerialization

      public DelegatingByTopicSerialization()

    • DelegatingByTopicSerialization

      public DelegatingByTopicSerialization(MapSE<PatternSE,T> delegates, T defaultDelegate)

  • メソッドの詳細

    • setCaseSensitive

      public void setCaseSensitive(boolean caseSensitive)
      false に設定すると、トピック名の大文字と小文字が区別されなくなります。
      パラメーター:
      caseSensitive - 大文字と小文字を区別しない場合は false。

    • configure

      protected void configure(MapSE<StringSE,?> configs, boolean isKey)

    • build

      protected void build(MapSE<StringSE,?> configs, boolean isKey, StringSE configKey, ObjectSE delegate, PatternSE pattern)

    • buildDefault

      protected void buildDefault(MapSE<StringSE,?> configs, StringSE configKey, boolean isKey, ObjectSE delegate)

    • configureDelegate

      protected abstract T configureDelegate(MapSE<StringSE,?> configs, boolean isKey, T delegate)
      デリゲートを構成します。
      パラメーター:
      configs - 構成。
      isKey - これがキーの場合は true。
      delegate - 代表者。
      戻り値:
      代表者。

    • isInstance

      protected abstract boolean isInstance(ObjectSE delegate)
      このオブジェクトが T のインスタンスである場合、true を返します。
      パラメーター:
      delegate - 代表者。
      戻り値:
      T の場合は true。

    • instantiateAndConfigure

      protected T instantiateAndConfigure(MapSE<StringSE,?> configs, boolean isKey, MapSE<PatternSE,T> delegates2, @Nullable PatternSE pattern, ClassSE<?> clazz)

    • addDelegate

      public void addDelegate(PatternSE pattern, T serializer)

    • removeDelegate

      @Nullable public T removeDelegate(PatternSE pattern)

    • findDelegate

      protected T findDelegate(StringSE topic)
      トピックのデリゲートを決定します。
      パラメーター:
      topic - トピック。
      戻り値:
      代表者。

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close