T - target class for serialization/deserializationpublic class JsonSerde<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serde<T>
Serde that provides serialization and
deserialization in JSON format.
The implementation delegates to underlying JsonSerializer and
JsonDeserializer implementations.
| Constructor and Description |
|---|
JsonSerde() |
JsonSerde(java.lang.Class<? super T> targetType) |
JsonSerde(java.lang.Class<? super T> targetTypeArg,
com.fasterxml.jackson.databind.ObjectMapper objectMapperArg) |
JsonSerde(JsonSerializer<T> jsonSerializer,
JsonDeserializer<T> jsonDeserializer) |
JsonSerde(com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
org.apache.kafka.common.serialization.Deserializer<T> |
deserializer() |
JsonSerde<T> |
dontRemoveTypeHeaders()
Don't remove type information headers after deserialization.
|
JsonSerde<T> |
forKeys()
Designate this Serde for serializing/deserializing keys (default is values).
|
JsonSerde<T> |
ignoreTypeHeaders()
Ignore type information headers and use the configured target class.
|
JsonSerde<T> |
noTypeInfo()
Configure the serializer to not add type information.
|
org.apache.kafka.common.serialization.Serializer<T> |
serializer() |
JsonSerde<T> |
setUseTypeMapperForKey(boolean isKey)
Deprecated.
in favor of
forKeys(). |
JsonSerde<T> |
typeMapper(Jackson2JavaTypeMapper mapper)
Use the supplied
Jackson2JavaTypeMapper. |
public JsonSerde()
public JsonSerde(java.lang.Class<? super T> targetType)
public JsonSerde(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
public JsonSerde(@Nullable
java.lang.Class<? super T> targetTypeArg,
@Nullable
com.fasterxml.jackson.databind.ObjectMapper objectMapperArg)
public JsonSerde(JsonSerializer<T> jsonSerializer, JsonDeserializer<T> jsonDeserializer)
public void configure(java.util.Map<java.lang.String,?> configs,
boolean isKey)
configure in interface org.apache.kafka.common.serialization.Serde<T>public void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface org.apache.kafka.common.serialization.Serde<T>public org.apache.kafka.common.serialization.Serializer<T> serializer()
serializer in interface org.apache.kafka.common.serialization.Serde<T>public org.apache.kafka.common.serialization.Deserializer<T> deserializer()
deserializer in interface org.apache.kafka.common.serialization.Serde<T>@Deprecated public JsonSerde<T> setUseTypeMapperForKey(boolean isKey)
forKeys().isKey - Use key type headers if truepublic JsonSerde<T> forKeys()
public JsonSerde<T> noTypeInfo()
public JsonSerde<T> dontRemoveTypeHeaders()
public JsonSerde<T> ignoreTypeHeaders()
public JsonSerde<T> typeMapper(Jackson2JavaTypeMapper mapper)
Jackson2JavaTypeMapper.mapper - the mapper.