diff --git a/example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java b/example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java index 0607fc66..478cc304 100644 --- a/example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java +++ b/example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java @@ -28,7 +28,7 @@ public class ClusterCanalClientTest extends AbstractCanalClientTest { // "stability_test", "", ""); // 基于zookeeper动态获取canal server的地址,建立链接,其中一台server发生crash,可以支持failover - CanalConnector connector = CanalConnectors.newClusterConnector("10.218.140.189:2181", destination, "", ""); + CanalConnector connector = CanalConnectors.newClusterConnector("127.0.0.1:2181", destination, "", ""); final ClusterCanalClientTest clientTest = new ClusterCanalClientTest(destination); clientTest.setConnector(connector);