クラス JsonMessageConverter

java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
実装済みのインターフェース一覧:
MessageConverter, RecordMessageConverter
既知の直属サブクラス
ByteArrayJsonMessageConverter, BytesJsonMessageConverter, StringJsonMessageConverter
@DeprecatedSE(forRemoval=true, since="4.0") public class JsonMessageConverter extends MessagingMessageConverter
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
4.0 以降、Jackson 3 では JacksonJsonMessageConverter が優先されます。
JSON メッセージコンバーターの基本クラス。コンシューマー側では、byte[]、Bytes、StringSE レコード値を処理できます。プロデューサー側で、対応する Kafka シリアライザーに一致するサブクラスを選択します。
導入:
2.3
作成者:
Gary Russell

  • フィールド概要

    クラス MessagingMessageConverter から継承されたフィールド

    logger

  • コンストラクター概要

    コンストラクター
    コンストラクター
    説明
    JsonMessageConverter()
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    JsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

  • 方法の概要

    修飾子と型
    メソッド
    説明
    protected @Nullable ObjectSE
    convertPayload(Message<?> message)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。
    protected ObjectSE
    extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable TypeSE type)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    サブクラスは値を変換できます。デフォルトでは、変換できる SmartMessageConverter がない限り、Kafka によって提供されるものとして返されます。
    protected com.fasterxml.jackson.databind.ObjectMapper
    getObjectMapper()
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    オブジェクトマッパーを返します。
    Jackson2JavaTypeMapper
    getTypeMapper()
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    protected org.apache.kafka.common.header.Headers
    initialRecordHeaders(Message<?> message)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    サブクラスは、マップされる前に追加のヘッダーを設定できます。
    void
    setTypeMapper(Jackson2JavaTypeMapper typeMapper)
    非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
    カスタマイズされた型マッパーを設定します。

    クラス MessagingMessageConverter から継承されたメソッド

    fromMessage, getMessagingConverter, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, setMessagingConverter, setRawRecordHeader, toMessage

    クラス ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース MessageConverter から継承されたメソッド

    commonHeaders

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

    • JsonMessageConverter

      public JsonMessageConverter()
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

    • JsonMessageConverter

      public JsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

  • 方法の詳細

    • getTypeMapper

      public Jackson2JavaTypeMapper getTypeMapper()
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

    • setTypeMapper

      public void setTypeMapper(Jackson2JavaTypeMapper typeMapper)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      カスタマイズされた型マッパーを設定します。
      パラメーター:
      typeMapper - 型マッパー。

    • getObjectMapper

      protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      オブジェクトマッパーを返します。
      戻り値:
      マッパー。

    • initialRecordHeaders

      protected org.apache.kafka.common.header.Headers initialRecordHeaders(Message<?> message)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスは、マップされる前に追加のヘッダーを設定できます。
      オーバーライド:
      クラス MessagingMessageConverter の initialRecordHeaders 
      パラメーター:
      message - メッセージ。
      戻り値:
      ヘッダー

    • convertPayload

      protected @Nullable ObjectSE convertPayload(Message<?> message)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。
      オーバーライド:
      クラス MessagingMessageConverter の convertPayload 
      パラメーター:
      message - メッセージ。
      戻り値:
      ペイロード。

    • extractAndConvertValue

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