Simulation von Downstream-Fehlern mittels WebTestClient ExchangeFilterFunction

public class CircuitBreakerTestFilter {
    public static ExchangeFilterFunction injectError(HttpStatus status) {
        return (request, next) -> {
            if (request.url().getPath().contains("/external-api")) {
                return Mono.just(ClientResponse.create(status)
                    .header("Content-Type", "application/json")
                    .build());
            }
            return next.exchange(request);
        };
    }
}