src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -35,6 +35,11 @@ } public void disconnect(){ // 关闭连接 connector.disconnect(); } public void doStart() { Message message = null; @@ -48,7 +53,7 @@ "thread interrupt , current connector host: {} , port: {} ", endpointInstance.getHost(), endpointInstance.getPort()); Thread.currentThread().interrupt(); connector.disconnect(); disconnect(); } else { sleep(endpointInstance.getAcquireInterval()); }