public class StringJsonMessageConverter extends MessagingMessageConverter
| 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, toMessagepublic StringJsonMessageConverter()
public StringJsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
protected java.lang.Object convertPayload(org.springframework.messaging.Message<?> message)
MessagingMessageConverterconvertPayload in class MessagingMessageConvertermessage - the message.protected java.lang.Object extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
java.lang.reflect.Type type)
MessagingMessageConverterextractAndConvertValue in class MessagingMessageConverterrecord - the record.type - the required type.