Class ByteArrayJacksonJsonMessageConverter

java.lang.Object

org.springframework.kafka.support.converter.MessagingMessageConverter

org.springframework.kafka.support.converter.JacksonJsonMessageConverter

org.springframework.kafka.support.converter.ByteArrayJacksonJsonMessageConverter

All Implemented Interfaces:

MessageConverter, RecordMessageConverter

public class ByteArrayJacksonJsonMessageConverter
extends JacksonJsonMessageConverter

JSON Message converter that uses Jackson 3 - byte[] on output, String, Bytes, or byte[] on input. Used in conjunction with Kafka ByteArraySerializer/(ByteArrayDeserializer, BytesDeserializer, or StringDeserializer). More efficient than StringJacksonJsonMessageConverter because the String<->byte[] conversion is avoided.

Since:

4.0

Field Summary

Fields inherited from class MessagingMessageConverter

logger

Constructor Summary

Constructors

Constructor	Description
ByteArrayJacksonJsonMessageConverter()
ByteArrayJacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)

Method Summary

Modifier and Type	Method	Description
protected @Nullable Object	convertPayload(org.springframework.messaging.Message<?> message)	Subclasses can convert the payload; by default, it's sent unchanged to Kafka.

Methods inherited from class JacksonJsonMessageConverter

extractAndConvertValue, getJsonMapper, getTypeMapper, initialRecordHeaders, setTypeMapper

Methods inherited from class MessagingMessageConverter

fromMessage, getMessagingConverter, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, setMessagingConverter, setRawRecordHeader, toMessage

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface MessageConverter

commonHeaders

Constructor Details

ByteArrayJacksonJsonMessageConverter

public ByteArrayJacksonJsonMessageConverter()

ByteArrayJacksonJsonMessageConverter

public ByteArrayJacksonJsonMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)

Method Details

convertPayload

protected @Nullable Object convertPayload(org.springframework.messaging.Message<?> message)

Description copied from class: MessagingMessageConverter

Subclasses can convert the payload; by default, it's sent unchanged to Kafka.

Overrides:

convertPayload in class JacksonJsonMessageConverter

Parameters:

message - the message.

Returns:

the payload.