クラス ByteArrayJacksonJsonMessageConverter
java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JacksonJsonMessageConverter
org.springframework.kafka.support.converter.ByteArrayJacksonJsonMessageConverter
- 実装済みのインターフェース一覧:
MessageConverter, RecordMessageConverter
出力に Jackson 3 -
byte[]、入力に文字列、バイト列、byte[] を使用する JSON メッセージコンバーターです。Kafka ByteArraySerializer/(ByteArrayDeserializer, BytesDeserializer, or StringDeserializer) と組み合わせて使用します。String<->byte[] 変換を回避するため、StringJacksonJsonMessageConverter よりも効率的です。- 導入:
- 4.0
- 作成者:
- Soby Chacko
フィールド概要
クラス MessagingMessageConverter から継承されたフィールド
loggerコンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明protected @Nullable ObjectSEconvertPayload(Message<?> message) サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。クラス JacksonJsonMessageConverter から継承されたメソッド
extractAndConvertValue, getJsonMapper, getTypeMapper, initialRecordHeaders, setTypeMapperクラス MessagingMessageConverter から継承されたメソッド
fromMessage, getMessagingConverter, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, setMessagingConverter, setRawRecordHeader, toMessageクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース MessageConverter から継承されたメソッド
commonHeaders
コンストラクターの詳細
ByteArrayJacksonJsonMessageConverter
public ByteArrayJacksonJsonMessageConverter()ByteArrayJacksonJsonMessageConverter
public ByteArrayJacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)
方法の詳細
convertPayload
クラスからコピーされた説明:MessagingMessageConverterサブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。- オーバーライド:
- クラス
JacksonJsonMessageConverterのconvertPayload - パラメーター:
message- メッセージ。- 戻り値:
- ペイロード。