クラス StringJacksonJsonMessageConverter
java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JacksonJsonMessageConverter
org.springframework.kafka.support.converter.StringJacksonJsonMessageConverter
- 実装済みのインターフェース一覧:
MessageConverter, RecordMessageConverter
出力に Jackson 3 - 文字列、入力に文字列、バイト、byte[] を使用する JSON メッセージコンバーターです。Kafka(
StringSerializer/(StringDeserializer, BytesDeserializer, or ByteArrayDeserializer))と組み合わせて使用します。不要な String->byte[] 変換を避けるため、代わりに ByteArrayJsonMessageConverter の使用を検討してください。- 導入:
- 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
コンストラクターの詳細
StringJacksonJsonMessageConverter
public StringJacksonJsonMessageConverter()StringJacksonJsonMessageConverter
public StringJacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper objectMapper)
方法の詳細
convertPayload
クラスからコピーされた説明:MessagingMessageConverterサブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。- オーバーライド:
- クラス
JacksonJsonMessageConverterのconvertPayload - パラメーター:
message- メッセージ。- 戻り値:
- ペイロード。