diff --git a/src/CanalSharp.Client/Impl/CanalConnectors.cs b/src/CanalSharp.Client/Impl/CanalConnectors.cs
index 6ab5c85..f60eb42 100644
--- a/src/CanalSharp.Client/Impl/CanalConnectors.cs
+++ b/src/CanalSharp.Client/Impl/CanalConnectors.cs
@@ -31,7 +31,7 @@ namespace CanalSharp.Client.Impl
         {
             var canalConnector = new SimpleCanalConnector(address, port, username, password, destination)
             {
-                SoTimeout = 60 * 1000,
+                SoTimeOut = 60 * 1000,
                 IdleTimeOut = 60 * 60 * 1000
             };
             return canalConnector;
diff --git a/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs b/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs
index 31e1017..2fe2cce 100644
--- a/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs
+++ b/src/CanalSharp.Client/Impl/SimpleCanalConnector.cs
@@ -19,13 +19,11 @@ using System.Collections.Generic;
 using System.IO;
 using System.Linq;
 using System.Net.Sockets;
-using System.Threading.Tasks;
 using CanalSharp.Common.Logging;
 using CanalSharp.Protocol;
 using CanalSharp.Protocol.Exception;
 using Com.Alibaba.Otter.Canal.Protocol;
 using DotNetty.Transport.Channels;
-using DotNetty.Transport.Channels.Sockets;
 using Google.Protobuf;
 using Microsoft.Extensions.Logging;