T - class of the entity, representing messagesErrorHandlingDeserializer2.@Deprecated
public class ErrorHandlingDeserializer<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
Deprecated.
Property name for the delegate key deserializer.
|
static java.lang.String |
VALUE_DESERIALIZER_CLASS
Deprecated.
Property name for the delegate value deserializer.
|
| Constructor and Description |
|---|
ErrorHandlingDeserializer()
Deprecated.
|
ErrorHandlingDeserializer(org.apache.kafka.common.serialization.Deserializer<T> delegate)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Deprecated.
|
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey)
Deprecated.
|
T |
deserialize(java.lang.String topic,
byte[] data)
Deprecated.
|
T |
deserialize(java.lang.String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data)
Deprecated.
|
public static final java.lang.String KEY_DESERIALIZER_CLASS
public static final java.lang.String VALUE_DESERIALIZER_CLASS
public ErrorHandlingDeserializer()
public ErrorHandlingDeserializer(org.apache.kafka.common.serialization.Deserializer<T> delegate)
public void configure(java.util.Map<java.lang.String,?> configs,
boolean isKey)
configure in interface org.apache.kafka.common.serialization.Deserializer<T>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.Closeableclose in interface java.lang.AutoCloseableclose in interface org.apache.kafka.common.serialization.Deserializer<T>