环境信息
canal.deployer-1.1.3-SNAPSHOT canal.client 1.1.2 zookeeper 3.4.13
问题描述
客户端连接
集群: CanalConnector connector = CanalConnectors.newClusterConnector("192.168.1.11:2181", destination, "canal", "canal");
直连: CanalConnector connector = CanalConnectors.newSingleConnector( new InetSocketAddress("192.168.1.11", 11111), destination, "canal", "canal");
异常: com.alibaba.otter.canal.protocol.exception.CanalClientException: java.net.ConnectException: Connection timed out: connect at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:189) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.access$000(SimpleCanalConnector.java:50) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector$1.processActiveEnter(SimpleCanalConnector.java:422) at com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor.processActiveEnter(ClientRunningMonitor.java:211) at com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor.initRunning(ClientRunningMonitor.java:122) at com.alibaba.otter.canal.client.impl.running.ClientRunningMonitor.start(ClientRunningMonitor.java:92) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.connect(SimpleCanalConnector.java:106) at com.alibaba.otter.canal.client.impl.ClusterCanalConnector.connect(ClusterCanalConnector.java:64) at com.gta.canal.redis.AbstractCanalClient.process(AbstractCanalClient.java:112) at com.gta.canal.redis.AbstractCanalClient$2.run(AbstractCanalClient.java:77) at java.lang.Thread.run(Thread.java:748) Caused by: java.net.ConnectException: Connection timed out: connect at sun.nio.ch.Net.connect0(Native Method) at sun.nio.ch.Net.connect(Net.java:454) at sun.nio.ch.Net.connect(Net.java:446) at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:648) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.doConnect(SimpleCanalConnector.java:148) ... 10 common frames omitted
是不是版本冲突?
原提问者GitHub用户
根据您提供的信息,这个异常是由于连接超时引起的。无法确定是否是版本冲突导致的,需要进一步排查。
首先,建议您检查一下Canal Server和Zookeeper的版本是否兼容。您现在使用的Canal版本是1.1.3-SNAPSHOT,Zookeeper使用的是3.4.13版本,这两个版本是否匹配需要进一步验证。
其次,如果版本兼容无误,可以检查一下Canal Server和Zookeeper的启动状态是否正常,以及检查一下Canal Connector连接的参数是否正确。
最后,如果以上步骤没有发现问题,可以尝试通过增加连接超时的配置来解决连接超时的问题,例如可以通过CanalConnector#getConnector(Long timeout)
方法来设置连接超时时间。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。