A custom implementation of a Kafka Streams ProductionExceptionHandler that uses a SpringContext bridge to access beans.

CustomExceptionHandler.java

public class CustomExceptionHandler implements ProductionExceptionHandler {

  private ExceptionService exceptionService;

  public ProductionExceptionHandlerResponse handle(final ProducerRecord<byte[], byte[]> record, final Exception exception) {
    boolean shouldContinue = exceptionService.handleProductionException(record, exception);
    
    return shouldContinue ? CONTINUE : FAIL;
  }

  @Override
  public void configure(Map<String, ?> configs) {
    // tap into SpringContext to get the ExceptionService bean
    this.exceptionService = SpringContext.getBean(ExceptionService.class);
  }
}