From 2cebfa04dd6889141c408e94d64b4bedb4fc9cea Mon Sep 17 00:00:00 2001 From: agapple Date: Wed, 5 Jul 2017 12:48:52 +0800 Subject: [PATCH] fixed test --- .../com/alibaba/otter/canal/example/ClusterCanalClientTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);