public class DeserializationErrorHandlingJsonSerde<T> extends JsonSerde<T>
Modifier and Type | Class and Description |
---|---|
static class |
DeserializationErrorHandlingJsonSerde.DeserializationError |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs,
boolean isKey) |
T |
deserialize(String topic,
byte[] data) |
T |
deserialize(String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data) |
static <T> DeserializationErrorHandlingJsonSerde<T> |
serde(Class<T> clazz,
boolean isKey,
Function<DeserializationErrorHandlingJsonSerde.DeserializationError,T> handleDeserializationExceptionFunction) |
close, configure, deserializer, serde, serialize, serializer
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Deserializer<T>
configure
in interface org.apache.kafka.common.serialization.Serde<T>
configure
in interface org.apache.kafka.common.serialization.Serializer<T>
configure
in class JsonSerde<T>
public T deserialize(String topic, org.apache.kafka.common.header.Headers headers, byte[] data)
public T deserialize(String topic, byte[] data)
deserialize
in interface org.apache.kafka.common.serialization.Deserializer<T>
deserialize
in class JsonSerde<T>
public static <T> DeserializationErrorHandlingJsonSerde<T> serde(Class<T> clazz, boolean isKey, Function<DeserializationErrorHandlingJsonSerde.DeserializationError,T> handleDeserializationExceptionFunction)