Merge pull request sermant-io#1410 from lilai23/kafka_integration_test

修复禁止消费插件动态配置zone失效的问题
daizhenyu · Jan 10, 2024 · 1e32286 · 1e32286
2 parents ae59dcb + c037994
commit 1e32286
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../main/java/com/huaweicloud/sermant/core/plugin/subscribe/CommonGroupConfigSubscriber.java b/.../main/java/com/huaweicloud/sermant/core/plugin/subscribe/CommonGroupConfigSubscriber.java
@@ -135,7 +135,7 @@ private void buildZoneRequest() {
         final HashMap<String, String> map = new HashMap<>(REQUEST_MAP_SIZE);
         map.put(APP, config.getApplication());
         map.put(ENVIRONMENT, config.getEnvironment());
-        map.put(ZONE, config.getEnvironment());
+        map.put(ZONE, config.getZone());
         final String labelGroup = LabelGroupUtils.createLabelGroup(map);
         listenerCache.put(labelGroup, new IntegratedEventListenerAdapter(configOrderIntegratedProcessor, labelGroup));
         configOrderIntegratedProcessor.addHolder(new ConfigDataHolder(labelGroup, ZONE_ORDER));