THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The basic interface added will be:
| Code Block | ||
|---|---|---|
| ||
/** |
...
* An interface that allows user code to inspect a record that has failed processing |
...
*/ |
...
public interface RecordExceptionHandler { |
...
/** |
...
* Inspect a record and its context |
...
*/ |
...
void handle(ConsumerRecord<byte[], byte[]> record, RecordContext context, ExceptionType exceptionType); } |
}
Users will be able to set an exception handler through the following new config option:
...