Page History

...

• A public enumeration, ProductionExceptionHandlerResponse, with two possible values: CONTINUE and FAIL
• A public interface named ProductionExceptionHandler with a single method, handle, that has the following signature:
  • ProductionExceptionHandlerResponse handle(ProducerRecord<byte[], byte[]> record, Exception exception)
• Two default implementations of ProductionExceptionHandler
  • The AlwaysFailProductionExceptionHandler, the default implementation that maintains the current behavior of always failing when production exceptions occur.
  • The AlwaysContinueProductionExceptionHandler that instructs Streams to always attempt to continue processing in light of production exceptions.
• A new configuration parameter for Streams named default.production.exception.handler that accepts the fully qualified class name of the ProductionExceptionHandler to use.

...