THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
public static final String DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG = "default.deserialization.exception.handler"
One configuration option will be introduced (to be passed on RecordExceptionHandler.configure()) with type "HandlerResponse". This effectively tells the exception handler whether to continue or fail. In the future we might consider adding other options as well.
public static final String DEFAULT_DESERIALIZATION_EXCEPTION_RESPONSE = "default.deserialization.exception.response"
One default implementation of the interface will be provided:
Code Block | ||
---|---|---|
| ||
public class DefaultExceptionHandler implements RecordExceptionHandler {...}
// Then in StreamsConfig.java:
.define(DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG,
Type.CLASS,
DefaultExceptionHandler.class.getName(),
Importance.MEDIUM,
DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC)
.define(DEFAULT_DESERIALIZATION_EXCEPTION_RESPONSE_CONFIG,
Type.STRING,
HandlerResponse.FAIL.toString(),
Importance.MEDIUM,
DEFAULT_DESERIALIZATION_EXCEPTION_RESPONSE_DOC) |
Compatibility, Deprecation, and Migration Plan
...