diff --git a/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java b/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java index 282bdef679..e0e9a86dda 100644 --- a/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java +++ b/dubbo-configcenter/dubbo-configcenter-consul/src/main/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfiguration.java @@ -145,7 +145,7 @@ public class ConsulDynamicConfiguration implements DynamicConfiguration { // } // return true; String normalizedKey = convertKey(group, key); - return kvClient.putValue(normalizedKey + PATH_SEPARATOR + content); + return kvClient.putValue(normalizedKey, content); } @Override diff --git a/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java b/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java index 8ada5fbdc0..d924c834e4 100644 --- a/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java +++ b/dubbo-configcenter/dubbo-configcenter-consul/src/test/java/org/apache/dubbo/configcenter/consul/ConsulDynamicConfigurationTest.java @@ -102,6 +102,12 @@ public class ConsulDynamicConfigurationTest { System.out.println(kvClient.getValues("/dubbo/config/dubbo/foo")); } + @Test + public void testPublishConfig() { + configuration.publishConfig("foo", "value1"); + Assertions.assertEquals("value1", configuration.getString("/dubbo/config/dubbo/foo")); + } + @Test public void testGetConfigKeys() {