Class JacksonJsonSerde<T>

java.lang.Object
org.springframework.kafka.support.serializer.JacksonJsonSerde<T>
Type Parameters:
T - target class for serialization/deserialization
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serde<T>
public class JacksonJsonSerde<T> extends Object implements org.apache.kafka.common.serialization.Serde<T>
A Serde that provides serialization and deserialization in JSON format. Based on Jackson 3.

The implementation delegates to underlying JacksonJsonSerializer and JacksonJsonDeserializer implementations.

Since:
4.0
Author:
Marius Bogoevici, Elliot Kennedy, Gary Russell, Ivan Ponomarev, Soby Chacko

  • Constructor Details

    • JacksonJsonSerde

      public JacksonJsonSerde()

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable Class<? super T> targetType)

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable tools.jackson.core.type.TypeReference<? super T> targetType)

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable tools.jackson.databind.JavaType targetType)

    • JacksonJsonSerde

      public JacksonJsonSerde(tools.jackson.databind.json.JsonMapper jsonMapper)

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable tools.jackson.core.type.TypeReference<? super T> targetType, tools.jackson.databind.json.JsonMapper jsonMapper)

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable Class<? super T> targetType, tools.jackson.databind.json.JsonMapper jsonMapper)

    • JacksonJsonSerde

      public JacksonJsonSerde(@Nullable tools.jackson.databind.JavaType targetTypeArg, @Nullable tools.jackson.databind.json.JsonMapper jsonMapperArg)

    • JacksonJsonSerde

      public JacksonJsonSerde(JacksonJsonSerializer<T> jsonSerializer, JacksonJsonDeserializer<T> jsonDeserializer)

  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Serde<T>

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.common.serialization.Serde<T>

    • serializer

      public JacksonJsonSerializer<T> serializer()
      Specified by:
      serializer in interface org.apache.kafka.common.serialization.Serde<T>

    • deserializer

      public JacksonJsonDeserializer<T> deserializer()
      Specified by:
      deserializer in interface org.apache.kafka.common.serialization.Serde<T>

    • copyWithType

      public <X> JacksonJsonSerde<X> copyWithType(Class<? super X> newTargetType)
      Copies this serde with same configuration, except new target type is used.
      Type Parameters:
      X - new deserialization result type and serialization source type
      Parameters:
      newTargetType - type reference forced for serialization, and used as default for deserialization, not null
      Returns:
      new instance of serde with type changes

    • copyWithType

      public <X> JacksonJsonSerde<X> copyWithType(tools.jackson.core.type.TypeReference<? super X> newTargetType)
      Copies this serde with same configuration, except new target type reference is used.
      Type Parameters:
      X - new deserialization result type and serialization source type
      Parameters:
      newTargetType - type reference forced for serialization, and used as default for deserialization, not null
      Returns:
      new instance of serde with type changes

    • copyWithType

      public <X> JacksonJsonSerde<X> copyWithType(tools.jackson.databind.JavaType newTargetType)
      Copies this serde with same configuration, except new target java type is used.
      Type Parameters:
      X - new deserialization result type and serialization source type
      Parameters:
      newTargetType - java type forced for serialization, and used as default for deserialization, not null
      Returns:
      new instance of serde with type changes

    • forKeys

      public JacksonJsonSerde<T> forKeys()
      Designate this Serde for serializing/deserializing keys (default is values).
      Returns:
      the serde.

    • noTypeInfo

      public JacksonJsonSerde<T> noTypeInfo()
      Configure the serializer to not add type information.
      Returns:
      the serde.

    • dontRemoveTypeHeaders

      public JacksonJsonSerde<T> dontRemoveTypeHeaders()
      Don't remove type information headers after deserialization.
      Returns:
      the serde.

    • ignoreTypeHeaders

      public JacksonJsonSerde<T> ignoreTypeHeaders()
      Ignore type information headers and use the configured target class.
      Returns:
      the serde.

    • typeMapper

      public JacksonJsonSerde<T> typeMapper(JacksonJavaTypeMapper mapper)
      Use the supplied JacksonJavaTypeMapper.
      Parameters:
      mapper - the mapper.
      Returns:
      the serde.