クラス ParseStringDeserializer<T>
java.lang.ObjectSE
org.springframework.kafka.support.serializer.ParseStringDeserializer<T>
- 型パラメーター:
T
- メッセージを表すエンティティのクラス
- 実装されたすべてのインターフェース:
CloseableSE
、AutoCloseableSE
、org.apache.kafka.common.serialization.Deserializer<T>
public class ParseStringDeserializer<T>
extends ObjectSE
implements org.apache.kafka.common.serialization.Deserializer<T>
Kafka から受信した
String
SE 表現からエンティティを逆直列化するための汎用 Deserializer
(別名、解析)。- 導入:
- 2.5
- 作成者:
- Alexei Klenin, Gary Russell, Wang Zhiyang
フィールドサマリー
フィールドコンストラクターのサマリー
コンストラクターコンストラクター説明パーサー関数を使用せずにインスタンスを作成します。静的メソッド名は、コンシューマー構成のKEY_PARSER
またはVALUE_PARSER
プロパティで指定する必要があります。ParseStringDeserializer
(BiFunctionSE<StringSE, org.apache.kafka.common.header.Headers, T> parser) 提供されているパーサー関数を使用してインスタンスを構築します。ParseStringDeserializer
(FunctionSE<StringSE, T> parser) 提供されているパーサー関数を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明void
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) 構成された文字セットを取得します。BiFunctionSE<StringSE,
org.apache.kafka.common.header.Headers, T> 構成されたパーサー関数を取得します。void
setCharset
(CharsetSE charset) byte[] をString
SE に変換するときに使用する文字セットを設定します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.apache.kafka.common.serialization.Deserializer から継承されたメソッド
close
フィールドの詳細
コンストラクターの詳細
ParseStringDeserializer
public ParseStringDeserializer()パーサー関数を使用せずにインスタンスを作成します。静的メソッド名は、コンシューマー構成のKEY_PARSER
またはVALUE_PARSER
プロパティで指定する必要があります。ParseStringDeserializer
提供されたパーサー関数を使用してインスタンスを構築します。この関数は、たとえば圧縮されたトピック内の tombstone レコードの場合、入力値として null を受け取ることがあります。- パラメーター:
parser
- 関数。
ParseStringDeserializer
public ParseStringDeserializer(BiFunctionSE<StringSE, org.apache.kafka.common.header.Headers, T> parser) 提供されたパーサー関数を使用してインスタンスを構築します。この関数は、たとえば圧縮されたトピック内の tombstone レコードの場合、入力値として null を受け取ることがあります。- パラメーター:
parser
- 関数。
メソッドの詳細
configure
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のconfigure
deserialize
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のdeserialize
deserialize
- 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のdeserialize
deserialize
public T deserialize(StringSE topic, org.apache.kafka.common.header.Headers headers, ByteBufferSE data) - 次で指定:
- インターフェース
org.apache.kafka.common.serialization.Deserializer<T>
のdeserialize
setCharset
byte[] をString
SE に変換するときに使用する文字セットを設定します。デフォルトの UTF-8。- パラメーター:
charset
- 文字セット。
getCharset
構成された文字セットを取得します。- 戻り値:
- 文字セット。
getParser
構成されたパーサー関数を取得します。- 戻り値:
- 関数。