T
- class of the entity, representing messagespublic class ErrorHandlingDeserializer2<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Deserializer<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
Header 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) |
boolean |
isForKey() |
ErrorHandlingDeserializer2<T> |
keyDeserializer(boolean isKey)
Set to true if this deserializer is to be used as a key deserializer when
configuring outside of Kafka.
|
void |
setFailedDeserializationFunction(java.util.function.BiFunction<byte[],org.apache.kafka.common.header.Headers,T> failedDeserializationFunction)
Deprecated.
since 2.2.8 in favor of
setFailedDeserializationFunction(Function) . |
void |
setFailedDeserializationFunction(java.util.function.Function<FailedDeserializationInfo,T> failedDeserializationFunction)
Provide an alternative supplying mechanism when deserialization fails.
|
void |
setForKey(boolean isKey)
Set to true if this deserializer is to be used as a key deserializer when
configuring outside of Kafka.
|
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)
@Deprecated public void setFailedDeserializationFunction(java.util.function.BiFunction<byte[],org.apache.kafka.common.header.Headers,T> failedDeserializationFunction)
setFailedDeserializationFunction(Function)
.failedDeserializationFunction
- the BiFunction
to use.public void setFailedDeserializationFunction(java.util.function.Function<FailedDeserializationInfo,T> failedDeserializationFunction)
failedDeserializationFunction
- the Function
to use.public boolean isForKey()
public void setForKey(boolean isKey)
isKey
- true for a key deserializer, false otherwise.public ErrorHandlingDeserializer2<T> keyDeserializer(boolean isKey)
isKey
- true for a key deserializer, false otherwise.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.Deserializer<T>
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface org.apache.kafka.common.serialization.Deserializer<T>