From 11e1d1d6000be292d5c38d21a11c1a71583ecbdd Mon Sep 17 00:00:00 2001 From: lulu2panpan Date: Fri, 29 Apr 2016 09:31:40 +0800 Subject: [PATCH] Update CanalConnectors.java --- .../java/com/alibaba/otter/canal/client/CanalConnectors.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java b/client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java index 391b21dc..de0aa2e5 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java @@ -28,7 +28,7 @@ public class CanalConnectors { */ public static CanalConnector newSingleConnector(SocketAddress address, String destination, String username, String password) { - SimpleCanalConnector canalConnector = new SimpleCanalConnector(address, username, password, destination); + SimpleCanalConnector canalConnector = new SimpleCanalConnector(address, username, password, destination, null); canalConnector.setSoTimeout(30 * 1000); return canalConnector; }