diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java index 58342d2c..5f29816f 100644 --- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java +++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java @@ -52,7 +52,7 @@ public class CompositeRouteDefinitionLocator implements RouteDefinitionLocator { return this.delegates.flatMap(RouteDefinitionLocator::getRouteDefinitions) .flatMap(routeDefinition -> Mono.justOrEmpty(routeDefinition.getId()) .defaultIfEmpty(idGenerator.generateId().toString()) - .publishOn(Schedulers.elastic()).map(id -> { + .publishOn(Schedulers.boundedElastic()).map(id -> { routeDefinition.setId(id); if (log.isDebugEnabled()) { log.debug(