T- the expected type
public interface DeserializationFailureHandler<T>
Implementors must use
@Identifier to provide a name to the bean.
This name is then referenced in the channel configuration:
When a Kafka Record's key or value cannot be deserialized, this bean is called to provide a fallback value.
null is an accepted fallback value.
If this bean throws an exception, this is considered as a fatal failure and the application is reported unhealthy.
|Modifier and Type||Method and Description|
Handles a deserialization issue for a record's key or value.
default T handleDeserializationFailure(String topic, boolean isKey, String deserializer, byte data, Exception exception, org.apache.kafka.common.header.Headers headers)
topic- the topic
isKey- whether the failure happened when deserializing a record's key.
deserializer- the used deserializer
data- the data that was not deserialized correctly
exception- the exception
headers- the record headers, extended with the failure reason, causes, and data. May also be
Copyright © 2018–2021 SmallRye. All rights reserved.