クラス 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
フィールドサマリー
クラス org.springframework.kafka.support.serializer.DelegatingByTopicSerialization から継承されたフィールド
CASE_SENSITIVE, KEY_SERIALIZATION_TOPIC_CONFIG, KEY_SERIALIZATION_TOPIC_DEFAULT, VALUE_SERIALIZATION_TOPIC_CONFIG, VALUE_SERIALIZATION_TOPIC_DEFAULT
コンストラクターのサマリー
コンストラクターコンストラクター説明コンシューマープロパティを使用してconfigure(Map, boolean)
で構成されるインスタンスを作成します。DelegatingByTopicDeserializer
(MapSE<PatternSE, org.apache.kafka.common.serialization.Deserializer<?>> delegates, org.apache.kafka.common.serialization.Deserializer<?> defaultDelegate) デシリアライザーを委譲するために、提供されたトピック名パターンのマッピングを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
protected org.apache.kafka.common.serialization.Deserializer<?>
configureDelegate
(MapSE<StringSE, ?> configs, boolean isKey, org.apache.kafka.common.serialization.Deserializer<?> delegate) デリゲートを構成します。deserialize
(StringSE topic, byte[] data) deserialize
(StringSE topic, org.apache.kafka.common.header.Headers headers, byte[] data) deserialize
(StringSE topic, org.apache.kafka.common.header.Headers headers, ByteBufferSE data) protected boolean
isInstance
(ObjectSE delegate) このオブジェクトが T のインスタンスである場合、true を返します。クラス 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.Deserializer から継承されたメソッド
close
コンストラクターの詳細
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
- 次で指定:
- インターフェース
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
クラスからコピーされた説明:DelegatingByTopicSerialization
このオブジェクトが T のインスタンスである場合、true を返します。- 次で指定:
- クラス
DelegatingByTopicSerialization<org.apache.kafka.common.serialization.Deserializer<?>>
のisInstance
- パラメーター:
delegate
- 代表者。- 戻り値:
- T の場合は true。
deserialize
- 次で指定:
- インターフェース
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