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

クラス 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 から受信した StringSE 表現からエンティティを逆直列化するための汎用 Deserializer (別名、解析)。
導入:
2.5
作成者:
Alexei Klenin, Gary Russell, Wang Zhiyang

  • フィールドの詳細

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

    • ParseStringDeserializer

      public ParseStringDeserializer()
      パーサー関数を使用せずにインスタンスを作成します。静的メソッド名は、コンシューマー構成の KEY_PARSER または VALUE_PARSER プロパティで指定する必要があります。

    • ParseStringDeserializer

      public ParseStringDeserializer(FunctionSE<StringSE,T> parser)
      提供されたパーサー関数を使用してインスタンスを構築します。この関数は、たとえば圧縮されたトピック内の tombstone レコードの場合、入力値として null を受け取ることがあります。
      パラメーター:
      parser - 関数。

    • ParseStringDeserializer

      public ParseStringDeserializer(BiFunctionSE<StringSE,org.apache.kafka.common.header.Headers,T> parser)
      提供されたパーサー関数を使用してインスタンスを構築します。この関数は、たとえば圧縮されたトピック内の tombstone レコードの場合、入力値として null を受け取ることがあります。
      パラメーター:
      parser - 関数。

  • 方法の詳細

    • configure

      public void configure(MapSE<StringSE,?> configs, boolean isKey)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> 内の configure 

    • deserialize

      public T deserialize(StringSE topic, byte[] data)
      次で指定:
      インターフェース org.apache.kafka.common.serialization.Deserializer<T> 内の deserialize 

    • deserialize

      public T deserialize(StringSE topic, @Nullable org.apache.kafka.common.header.Headers headers, byte[] data)
      次で指定:
      インターフェース 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

      public void setCharset(CharsetSE charset)
      byte[] を StringSE に変換するときに使用する文字セットを設定します。デフォルトの UTF-8。
      パラメーター:
      charset - 文字セット。

    • getCharset

      public CharsetSE getCharset()
      構成された文字セットを取得します。
      戻り値:
      文字セット。

    • getParser

      public BiFunctionSE<StringSE,org.apache.kafka.common.header.Headers,T> getParser()
      構成されたパーサー関数を取得します。
      戻り値:
      関数。