From 8aefd7e79bc52db947b4413ea3227221ebae7981 Mon Sep 17 00:00:00 2001 From: agapple Date: Fri, 29 Apr 2016 17:44:06 +0800 Subject: [PATCH] fixed issue #171, getNextAddress --- .../alibaba/otter/canal/client/impl/ClusterCanalConnector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java index 4a857f7d..d062b4ff 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java @@ -47,7 +47,7 @@ public class ClusterCanalConnector implements CanalConnector { currentConnector = new SimpleCanalConnector(null, username, password, destination) { @Override - public SocketAddress getAddress() { + public SocketAddress getNextAddress() { return accessStrategy.nextNode(); }