Page History

...

        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 as CONTINUE
• No need to implement in DefaultProductionExceptionHandler, as the return response is set to FAIL 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

...