パッケージ org.springframework.kafka.support.converter

クラス BytesJsonMessageConverter

java.lang.ObjectSE
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
org.springframework.kafka.support.converter.BytesJsonMessageConverter
実装されたすべてのインターフェース:
MessageConverter, RecordMessageConverter
public class BytesJsonMessageConverter extends JsonMessageConverter
JSON メッセージコンバーター - 出力の場合は Bytes、入力の場合は文字列、バイト、バイト []。Kafka BytesSerializer/(BytesDeserializer, ByteArrayDeserializer, or StringDeserializer) と組み合わせて使用します。String<->byte[] 変換が回避されるため、StringJsonMessageConverter よりも効率的です。
導入:
2.1.7
作成者:
Gary Russell, Vladimir Loginov

  • コンストラクターの詳細

    • BytesJsonMessageConverter

      public BytesJsonMessageConverter()

    • BytesJsonMessageConverter

      public BytesJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

  • メソッドの詳細

    • convertPayload

      protected ObjectSE convertPayload(Message<?> message)
      クラスからコピーされた説明: MessagingMessageConverter
      サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。
      オーバーライド:
      クラス JsonMessageConverter の convertPayload 
      パラメーター:
      message - メッセージ。
      戻り値:
      ペイロード。