reactor anti patterns - raisercostin/raisercostin.github.io GitHub Wiki

  • Don't Flux.onErrorContinue since it might hide the error Replace .onErrorContinue((error,item)->logger.warn("Couldn't process [{}]",item,error)) With .onErrorContinue((error,item)->{throw new RuntimeException("Couldn't process ["+item+"]",error);})