Class JsonMessageConverter

java.lang.Object
org.springframework.kafka.support.converter.MessagingMessageConverter
org.springframework.kafka.support.converter.JsonMessageConverter
All Implemented Interfaces:
MessageConverter, RecordMessageConverter
Direct Known Subclasses:
ByteArrayJsonMessageConverter, BytesJsonMessageConverter, StringJsonMessageConverter
@Deprecated(forRemoval=true, since="4.0") public class JsonMessageConverter extends MessagingMessageConverter
Deprecated, for removal: This API element is subject to removal in a future version.
since 4.0 in favor of JacksonJsonMessageConverter for Jackson 3.
Base class for JSON message converters; on the consumer side, it can handle byte[], Bytes and String record values. On the producer side, select a subclass that matches the corresponding Kafka Serializer.
Since:
2.3
Author:
Gary Russell

  • Constructor Details

    • JsonMessageConverter

      public JsonMessageConverter()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • JsonMessageConverter

      public JsonMessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
      Deprecated, for removal: This API element is subject to removal in a future version.

  • Method Details

    • getTypeMapper

      public Jackson2JavaTypeMapper getTypeMapper()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • setTypeMapper

      public void setTypeMapper(Jackson2JavaTypeMapper typeMapper)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Set a customized type mapper.
      Parameters:
      typeMapper - the type mapper.

    • getObjectMapper

      protected com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Return the object mapper.
      Returns:
      the mapper.

    • initialRecordHeaders

      protected org.apache.kafka.common.header.Headers initialRecordHeaders(Message<?> message)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Description copied from class: MessagingMessageConverter
      Subclasses can populate additional headers before they are mapped.
      Overrides:
      initialRecordHeaders in class MessagingMessageConverter
      Parameters:
      message - the message.
      Returns:
      the headers

    • convertPayload

      protected @Nullable Object convertPayload(Message<?> message)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Description copied from class: MessagingMessageConverter
      Subclasses can convert the payload; by default, it's sent unchanged to Kafka.
      Overrides:
      convertPayload in class MessagingMessageConverter
      Parameters:
      message - the message.
      Returns:
      the payload.

    • extractAndConvertValue

      protected Object extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable Type type)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Description copied from class: MessagingMessageConverter
      Subclasses can convert the value; by default, it's returned as provided by Kafka unless there is a SmartMessageConverter that can convert it.
      Overrides:
      extractAndConvertValue in class MessagingMessageConverter
      Parameters:
      record - the record.
      type - the required type.
      Returns:
      the value.