クラス BytesJsonMessageConverter
java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
org.springframework.kafka.support.converter.BytesJsonMessageConverter
- 実装されたすべてのインターフェース:
MessageConverter
,RecordMessageConverter
JSON メッセージコンバーター - 出力の場合は
Bytes
、入力の場合は文字列、バイト、バイト []。Kafka BytesSerializer/(BytesDeserializer, ByteArrayDeserializer, or StringDeserializer)
と組み合わせて使用します。String<->byte[]
変換が回避されるため、StringJsonMessageConverter
よりも効率的です。- 導入:
- 2.1.7
- 作成者:
- Gary Russell, Vladimir Loginov
フィールドサマリー
クラス org.springframework.kafka.support.converter.MessagingMessageConverter から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected ObjectSE
convertPayload
(Message<?> message) サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。クラス org.springframework.kafka.support.converter.JsonMessageConverter から継承されたメソッド
extractAndConvertValue, getObjectMapper, getTypeMapper, initialRecordHeaders, setTypeMapper
クラス 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
コンストラクターの詳細
BytesJsonMessageConverter
public BytesJsonMessageConverter()BytesJsonMessageConverter
public BytesJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
メソッドの詳細
convertPayload
クラスからコピーされた説明:MessagingMessageConverter
サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。- オーバーライド:
- クラス
JsonMessageConverter
のconvertPayload
- パラメーター:
message
- メッセージ。- 戻り値:
- ペイロード。