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, setTypeMapperfromMessage, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, toMessageclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcommonHeaders, getGroupIdpublic BytesJsonMessageConverter()
public BytesJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
protected java.lang.Object convertPayload(org.springframework.messaging.Message<?> message)
MessagingMessageConverterconvertPayload in class JsonMessageConvertermessage - the message.