public class StringJsonMessageConverter extends MessagingMessageConverter
logger
Constructor and Description |
---|
StringJsonMessageConverter() |
StringJsonMessageConverter(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.
|
protected java.lang.Object |
extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
java.lang.reflect.Type type)
Subclasses can convert the value; by default, it's returned as provided by Kafka.
|
fromMessage, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, toMessage
public StringJsonMessageConverter()
public StringJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
protected java.lang.Object convertPayload(org.springframework.messaging.Message<?> message)
MessagingMessageConverter
convertPayload
in class MessagingMessageConverter
message
- the message.protected java.lang.Object extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.reflect.Type type)
MessagingMessageConverter
extractAndConvertValue
in class MessagingMessageConverter
record
- the record.type
- the required type.