diff --git a/polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting/RateLimitingService.java b/polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting/RateLimitingService.java index 160a69677..ac24e72b9 100644 --- a/polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting/RateLimitingService.java +++ b/polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting/RateLimitingService.java @@ -213,6 +213,7 @@ private List parseResponse(String decodedValue, String name if (concurrentThreads != null) { RateLimitProto.ConcurrencyAmount.Builder concurrencyAmountBuilder = RateLimitProto.ConcurrencyAmount.newBuilder(); concurrencyAmountBuilder.setMaxAmount(concurrentThreads); + ruleBuilder.setResource(RateLimitProto.Rule.Resource.CONCURRENCY); ruleBuilder.setConcurrencyAmount(concurrencyAmountBuilder); }