public class BytesJsonMessageConverter extends JsonMessageConverter
Bytes
on output, String, Bytes, or byte[] on input.
Used in conjunction with Kafka BytesSerializer/BytesDeserializer
. More
efficient than StringJsonMessageConverter
because the String<->byte[]
conversion is avoided.logger
Constructor and Description |
---|
BytesJsonMessageConverter() |
BytesJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
convertPayload(org.springframework.messaging.Message<?> message)
Subclasses can convert the payload; by default, it's sent unchanged to Kafka.
|
extractAndConvertValue, getObjectMapper, getTypeMapper, initialRecordHeaders, setTypeMapper
fromMessage, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, toMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
commonHeaders, getGroupId
public BytesJsonMessageConverter()
public BytesJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
protected java.lang.Object convertPayload(org.springframework.messaging.Message<?> message)
MessagingMessageConverter
convertPayload
in class JsonMessageConverter
message
- the message.