T - class of the entity, representing messagespublic class ErrorHandlingDeserializer2<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.ExtendedDeserializer<T>
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
KEY_DESERIALIZER_CLASS
Property name for the delegate key deserializer.
|
static java.lang.String |
KEY_DESERIALIZER_EXCEPTION_HEADER
Header name for deserialization exceptions.
|
static java.lang.String |
KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX
Header name for deserialization exceptions.
|
static java.lang.String |
KEY_FUNCTION
Supplier for a T when deserialization fails.
|
static java.lang.String |
VALUE_DESERIALIZER_CLASS
Property name for the delegate value deserializer.
|
static java.lang.String |
VALUE_DESERIALIZER_EXCEPTION_HEADER
Heaader name for deserialization exceptions.
|
static java.lang.String |
VALUE_FUNCTION
Supplier for a T when deserialization fails.
|
| Constructor and Description |
|---|
ErrorHandlingDeserializer2() |
ErrorHandlingDeserializer2(org.apache.kafka.common.serialization.Deserializer<T> delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
T |
deserialize(java.lang.String topic,
byte[] data) |
T |
deserialize(java.lang.String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data) |
void |
setFailedDeserializationFunction(java.util.function.BiFunction<byte[],org.apache.kafka.common.header.Headers,T> failedDeserializationFunction) |
void |
setupDelegate(java.util.Map<java.lang.String,?> configs,
java.lang.String configKey) |
public static final java.lang.String KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX
public static final java.lang.String KEY_DESERIALIZER_EXCEPTION_HEADER
public static final java.lang.String VALUE_DESERIALIZER_EXCEPTION_HEADER
public static final java.lang.String KEY_FUNCTION
public static final java.lang.String VALUE_FUNCTION
public static final java.lang.String KEY_DESERIALIZER_CLASS
public static final java.lang.String VALUE_DESERIALIZER_CLASS
public ErrorHandlingDeserializer2()
public ErrorHandlingDeserializer2(org.apache.kafka.common.serialization.Deserializer<T> delegate)
public void setFailedDeserializationFunction(java.util.function.BiFunction<byte[],org.apache.kafka.common.header.Headers,T> failedDeserializationFunction)
public void configure(java.util.Map<java.lang.String,?> configs,
boolean isKey)
configure in interface org.apache.kafka.common.serialization.Deserializer<T>public void setupDelegate(java.util.Map<java.lang.String,?> configs,
java.lang.String configKey)
public T deserialize(java.lang.String topic, byte[] data)
deserialize in interface org.apache.kafka.common.serialization.Deserializer<T>public T deserialize(java.lang.String topic, org.apache.kafka.common.header.Headers headers, byte[] data)
deserialize in interface org.apache.kafka.common.serialization.ExtendedDeserializer<T>public void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface org.apache.kafka.common.serialization.Deserializer<T>