filter修改

config/config-etcd/src/main/java/com/jd/platform/jlog/etcd/EtcdListener.java

@@ -34,7 +34,7 @@ public class EtcdListener implements ConfigChangeListener {
 
     public EtcdListener() {
 
-        iterator = EtcdConfigurator.client.getKvClient().watch(ByteString.copyFromUtf8(ROOT)).asPrefix().start();
+        iterator = EtcdConfigurator.client.getKvClient().watch(ByteString.copyFromUtf8("/etcd/workers")).asPrefix().start();
         getExecutorService().submit(() -> {
             while (iterator.hasNext()){
                 try {

example/src/main/java/com/jd/platform/jlog/clientdemo/custom/CustomRespMap.java

@@ -1,22 +0,0 @@
-package com.jd.platform.jlog.clientdemo.custom;
-
-import com.jd.platform.jlog.client.cache.RespMap;
-import com.jd.platform.jlog.common.utils.FastJsonUtils;
-
-import java.util.Map;
-
-/**
- * @author tangbohu
- * @version 1.0.0
- * @ClassName CustomRespMap.java
- * @Description TODO
- * @createTime 2022年03月21日 20:39:00
- */
-public class CustomRespMap implements RespMap {
-
-    @Override
-    public Map<String, Object> appendRespMap(String cnt) {
-
-        return FastJsonUtils.toMap(cnt);
-    }
-}