クラス JacksonJsonMessageConverter

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

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

    • JacksonJsonMessageConverter

      public JacksonJsonMessageConverter()

    • JacksonJsonMessageConverter

      public JacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)

  • メソッドの詳細

    • getTypeMapper

      public JacksonJavaTypeMapper getTypeMapper()

    • setTypeMapper

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

    • getJsonMapper

      protected tools.jackson.databind.json.JsonMapper getJsonMapper()
      オブジェクトマッパーを返します。
      戻り値:
      マッパー。

    • initialRecordHeaders

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

    • convertPayload

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

    • extractAndConvertValue

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