クラス JsonMessageConverter
java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
- 実装されたすべてのインターフェース:
MessageConverter
,RecordMessageConverter
JSON メッセージコンバーターの基本クラス。コンシューマー側では、
byte[]
、Bytes
、String
SE レコード値を処理できます。プロデューサー側で、対応する Kafka シリアライザーに一致するサブクラスを選択します。- 導入:
- 2.3
- 作成者:
- Gary Russell
フィールドサマリー
クラス org.springframework.kafka.support.converter.MessagingMessageConverter から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected ObjectSE
convertPayload
(Message<?> message) サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。protected ObjectSE
extractAndConvertValue
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, TypeSE type) サブクラスは値を変換できます。デフォルトでは、変換できるSmartMessageConverter
がない限り、Kafka によって提供されるものとして返されます。protected com.fasterxml.jackson.databind.ObjectMapper
オブジェクトマッパーを返します。protected org.apache.kafka.common.header.Headers
initialRecordHeaders
(Message<?> message) サブクラスは、マップされる前に追加のヘッダーを設定できます。void
setTypeMapper
(Jackson2JavaTypeMapper typeMapper) カスタマイズされた型マッパーを設定します。クラス 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()JsonMessageConverter
public JsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
メソッドの詳細
getTypeMapper
setTypeMapper
カスタマイズされた型マッパーを設定します。- パラメーター:
typeMapper
- 型マッパー。
getObjectMapper
protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()オブジェクトマッパーを返します。- 戻り値:
- マッパー。
initialRecordHeaders
クラスからコピーされた説明:MessagingMessageConverter
サブクラスは、マップされる前に追加のヘッダーを設定できます。- オーバーライド:
- クラス
MessagingMessageConverter
のinitialRecordHeaders
- パラメーター:
message
- メッセージ。- 戻り値:
- ヘッダー
convertPayload
クラスからコピーされた説明: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
- 必要な型。- 戻り値:
- 値。