Package org.apache.kafka.streams.errors
Interface DeserializationExceptionHandler
-
- All Superinterfaces:
org.apache.kafka.common.Configurable
- All Known Implementing Classes:
LogAndContinueExceptionHandler
,LogAndFailExceptionHandler
public interface DeserializationExceptionHandler extends org.apache.kafka.common.Configurable
Interface that specifies how an exception from source node deserialization (e.g., reading from Kafka) should be handled.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
DeserializationExceptionHandler.DeserializationHandlerResponse
Enumeration that describes the response from the exception handler.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description DeserializationExceptionHandler.DeserializationHandlerResponse
handle(ProcessorContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, java.lang.Exception exception)
Inspect a record and the exception received.
-
-
-
Method Detail
-
handle
DeserializationExceptionHandler.DeserializationHandlerResponse handle(ProcessorContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, java.lang.Exception exception)
Inspect a record and the exception received.- Parameters:
context
- processor contextrecord
- record that failed deserializationexception
- the actual exception
-
-