クラス 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
フィールドのサマリー
クラス org.springframework.kafka.support.converter.MessagingMessageConverter から継承されたフィールド
loggerコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected @Nullable ObjectSEconvertPayload(Message<?> message) サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。クラス org.springframework.kafka.support.converter.JacksonJsonMessageConverter から継承されたメソッド
extractAndConvertValue, getJsonMapper, 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
コンストラクターの詳細
StringJacksonJsonMessageConverter
public StringJacksonJsonMessageConverter()StringJacksonJsonMessageConverter
public StringJacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper objectMapper)
メソッドの詳細
convertPayload
クラスからコピーされた説明:MessagingMessageConverterサブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。- オーバーライド:
- クラス
JacksonJsonMessageConverterのconvertPayload - パラメーター:
message- メッセージ。- 戻り値:
- ペイロード。