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();
                         }