Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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
languagejava
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

...