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

クラス JsonMessageConverter

java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
実装されたすべてのインターフェース:
MessageConverter, RecordMessageConverter
既知の直属サブクラス
ByteArrayJsonMessageConverter、BytesJsonMessageConverter、StringJsonMessageConverter
public class JsonMessageConverter extends MessagingMessageConverter
JSON メッセージコンバーターの基本クラス。コンシューマー側では、byte[]、Bytes、StringSE レコード値を処理できます。プロデューサー側で、対応する Kafka シリアライザーに一致するサブクラスを選択します。
導入:
2.3
作成者:
Gary Russell

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

    • JsonMessageConverter

      public JsonMessageConverter()

    • JsonMessageConverter

      public JsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

  • メソッドの詳細

    • getTypeMapper

      public Jackson2JavaTypeMapper getTypeMapper()

    • setTypeMapper

      public void setTypeMapper(Jackson2JavaTypeMapper typeMapper)
      カスタマイズされた型マッパーを設定します。
      パラメーター:
      typeMapper - 型マッパー。

    • getObjectMapper

      protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()
      オブジェクトマッパーを返します。
      戻り値:
      マッパー。

    • initialRecordHeaders

      protected org.apache.kafka.common.header.Headers initialRecordHeaders(Message<?> message)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスは、マップされる前に追加のヘッダーを設定できます。
      オーバーライド:
      クラス MessagingMessageConverter の initialRecordHeaders 
      パラメーター:
      message - メッセージ。
      戻り値:
      ヘッダー

    • convertPayload

      protected ObjectSE convertPayload(Message<?> message)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。
      オーバーライド:
      クラス MessagingMessageConverter の convertPayload 
      パラメーター:
      message - メッセージ。
      戻り値:
      ペイロード。

    • extractAndConvertValue

      protected ObjectSE extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, TypeSE type)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスは値を変換できます。デフォルトでは、変換できる SmartMessageConverter がない限り、Kafka によって提供されるものとして返されます。
      オーバーライド:
      クラス MessagingMessageConverter の extractAndConvertValue 
      パラメーター:
      record - レコード。
      type - 必要な型。
      戻り値:
      値。