...

/**
 * An interface that allows user code to inspect a record that has failed processing
 */
public interface RecordExceptionHandler {
 /**
  * Inspect a record and itsthe exception contextreceived
  */ 
 void handle(ConsumerRecord<byte[], byte[]> record, RecordContext context, ExceptionType exceptionTypeException exception);
}

Users will be able to set an exception handler through the following new config option:

...

Note that in all cases, the streams pipeline skips over the record after the handler is called (unless the handler stops the pipeline).  Contrast this with other possible options as described in Rejected Alternatives below.

We propose to add two exception types:

...

...

Compatibility, Deprecation, and Migration Plan

...