クラス 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

  • フィールド概要

    クラス org.springframework.kafka.support.converter.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 要素は、将来のバージョンで削除される可能性があります。
    カスタマイズされた型マッパーを設定します。

    クラス org.springframework.kafka.support.converter.MessagingMessageConverter から継承されたメソッド

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

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

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

    インターフェース org.springframework.kafka.support.converter.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 - 必要な型。
      戻り値:
      値。