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 10bcf871..cff34bb9 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 @@ -45,7 +45,7 @@ public class ClusterCanalConnector implements CanalConnector { int times = 0; while (true) { try { - currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination, ,accessStrategy); + currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination, accessStrategy); currentConnector.setSoTimeout(soTimeout); if (filter != null) { currentConnector.setFilter(filter);