...
ProductionExceptionHandlerResponse handleSerializationException(ProducerRecord record, Exception exception);
To accept different types of records from multiple topologies, ProducerRecord is defined without generics.The above interface method will have a default
implementation which returns ProductionExceptionHandlerResponse.FAIL
...
AlwaysContinueProductionExceptionHandler
and returns response asCONTINUE
- No need to implement in
DefaultProductionExceptionHandler,
as the return response is set toFAIL
by default.
We'll implement the following error handling logic to the send in RecordCollectorImpl. The new method, handleSerializationException
, in ProductionExceptionHandler will be invoked when
...