From d8c09ab9469d468f5985c32d35c29e56173b7fd6 Mon Sep 17 00:00:00 2001
From: FUNKYE <364176773@qq.com>
Date: Thu, 15 Apr 2021 22:28:21 +0800
Subject: [PATCH] bugfix: zk node path is converted to dataId error (#3635)
---
.../java/io/seata/config/zk/ZookeeperConfiguration.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/config/seata-config-zk/src/main/java/io/seata/config/zk/ZookeeperConfiguration.java b/config/seata-config-zk/src/main/java/io/seata/config/zk/ZookeeperConfiguration.java
index 8e80dd42c..70d681a8e 100644
--- a/config/seata-config-zk/src/main/java/io/seata/config/zk/ZookeeperConfiguration.java
+++ b/config/seata-config-zk/src/main/java/io/seata/config/zk/ZookeeperConfiguration.java
@@ -348,15 +348,16 @@ public class ZookeeperConfiguration extends AbstractConfiguration {
return;
}
-
- ConfigurationChangeEvent event = new ConfigurationChangeEvent().setDataId(s).setNewValue(o.toString())
- .setChangeType(ConfigurationChangeType.MODIFY);
+ String dataId = s.replaceFirst(ROOT_PATH + ZK_PATH_SPLIT_CHAR, "");
+ ConfigurationChangeEvent event = new ConfigurationChangeEvent().setDataId(dataId).setNewValue(o.toString())
+ .setChangeType(ConfigurationChangeType.MODIFY);
listener.onProcessEvent(event);
}
@Override
public void handleDataDeleted(String s) {
- ConfigurationChangeEvent event = new ConfigurationChangeEvent().setDataId(s).setChangeType(
+ String dataId = s.replaceFirst(ROOT_PATH + ZK_PATH_SPLIT_CHAR, "");
+ ConfigurationChangeEvent event = new ConfigurationChangeEvent().setDataId(dataId).setChangeType(
ConfigurationChangeType.DELETE);
listener.onProcessEvent(event);
}
--
GitLab