xc

ds-switch/src/main/java/com/zjty/switches/service/CanalClientExample.java

@@ -177,8 +177,8 @@ public class CanalClientExample implements CommandLineRunner {
         String jsonStr = JSONObject.toJSONString(changeData);
         System.out.println(jsonStr);
         try {
-            HttpUtils.sendPost("http://localhost:8080/test/add", jsonStr);
-//            HttpUtils.sendPost("http://localhost:8086/producer/receive", jsonStr);
+//            HttpUtils.sendPost("http://localhost:8080/test/add", jsonStr);
+            HttpUtils.sendPost("http://localhost:8086/producer/receive", jsonStr);
         } catch (UnsupportedEncodingException e) {
             e.printStackTrace();
         }