前提:集群搭建没有问题,java直接连接zk速度也很快,用Simple模式也很快,但是,
CanalConnector connector = CanalConnectors.newClusterConnector("200.200.200.64:2181", "es", "", ""); int batchSize = 1000; int emptyCount = 0; try { System.out.println("start connect"); connector.connect(); System.out.println("connect successed!"); connector.subscribe(".."); System.out.println("subscribeed !!"); ... 在connector.subscribe(".."); 非常慢,有时候还需要重启两次才能正常连接!! debug查看是 public void subscribe(String filter) throws CanalClientException { this.waitClientRunning();
发生问题,有什么办法可以解决?
原提问者GitHub用户wql6
你这是基于zookeeper的集群模式启动,上一次异常退出时尽量使用平滑退出,不要kill -9,正确调用disconnect
原回答者GitHub用户agapple
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。