THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
/**
* An interface that allows user code to inspect a record that has failed processing
*/
public interface RecordExceptionHandler {
/**
* Inspect a record and the exception received
*/
voidHandlerResponse handle(ConsumerRecord<byte[], byte[]> record, Exception exception);
}
public enum HandlerResponse {
/* continue with processing */
CONTINUE(1),
/* fail the processing and stop */
FAIL(2);
} |
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.
Compatibility, Deprecation, and Migration Plan
...