クラス 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
フィールドサマリー
クラス org.springframework.kafka.support.serializer.DelegatingByTopicSerialization から継承されたフィールド
CASE_SENSITIVE, KEY_SERIALIZATION_TOPIC_CONFIG, KEY_SERIALIZATION_TOPIC_DEFAULT, VALUE_SERIALIZATION_TOPIC_CONFIG, VALUE_SERIALIZATION_TOPIC_DEFAULT
コンストラクターのサマリー
コンストラクターコンストラクター説明プロデューサープロパティDelegatingByTopicSerialization.VALUE_SERIALIZATION_TOPIC_CONFIG
およびDelegatingByTopicSerialization.KEY_SERIALIZATION_TOPIC_CONFIG
を使用してconfigure(Map, boolean)
で構成されるインスタンスを作成します。DelegatingByTopicSerializer
(MapSE<PatternSE, org.apache.kafka.common.serialization.Serializer<?>> delegates, org.apache.kafka.common.serialization.Serializer<?> defaultDelegate) 提供されたトピックパターンのマッピングを使用してインスタンスを構築し、シリアライザーを委譲します。メソッドのサマリー
修飾子と型メソッド説明void
protected org.apache.kafka.common.serialization.Serializer<?>
configureDelegate
(MapSE<StringSE, ?> configs, boolean isKey, org.apache.kafka.common.serialization.Serializer<?> delegate) デリゲートを構成します。protected boolean
isInstance
(ObjectSE instance) このオブジェクトが T のインスタンスである場合、true を返します。byte[]
byte[]
クラス org.springframework.kafka.support.serializer.DelegatingByTopicSerialization から継承されたメソッド
addDelegate, build, buildDefault, close, findDelegate, instantiateAndConfigure, removeDelegate, setCaseSensitive
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.apache.kafka.common.serialization.Serializer から継承されたメソッド
close
コンストラクターの詳細
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
- 次で指定:
- インターフェース
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
クラスからコピーされた説明:DelegatingByTopicSerialization
このオブジェクトが T のインスタンスである場合、true を返します。- 次で指定:
- クラス
DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Serializer<?>>
のisInstance
- パラメーター:
instance
- 代表者。- 戻り値:
- T の場合は true。
serialize
- 次で指定:
- インターフェース
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