From fb25c726ab3dff22596ed6c4c5309d0ce7024860 Mon Sep 17 00:00:00 2001 From: qixiaobo Date: Mon, 7 Jun 2021 13:23:32 +0800 Subject: [PATCH] Dubbo 2.6.x may not support multi group consumer #7985 https://github.com/apache/dubbo/issues/7985 --- .../alibaba/dubbo/rpc/cluster/support/ClusterUtils.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/ClusterUtils.java b/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/ClusterUtils.java index 7bc6f30f7f0..c36af7d3b52 100644 --- a/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/ClusterUtils.java +++ b/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/ClusterUtils.java @@ -71,6 +71,14 @@ public static URL mergeUrl(URL remoteUrl, Map localMap) { if (dubbo != null && dubbo.length() > 0) { map.put(Constants.DUBBO_VERSION_KEY, dubbo); } + String defaultVersion = remoteMap.get(Constants.DEFAULT_KEY_PREFIX + Constants.VERSION_KEY); + if (defaultVersion != null && defaultVersion.length() > 0) { + map.put(Constants.DEFAULT_KEY_PREFIX + Constants.VERSION_KEY, defaultVersion); + } + String defaultGroup = remoteMap.get(Constants.DEFAULT_KEY_PREFIX + Constants.GROUP_KEY); + if (defaultGroup != null && defaultGroup.length() > 0) { + map.put(Constants.DEFAULT_KEY_PREFIX + Constants.GROUP_KEY, defaultGroup); + } String version = remoteMap.get(Constants.VERSION_KEY); if (version != null && version.length() > 0) { map.put(Constants.VERSION_KEY, version);