两个客户端同时运行并订阅了同一个canal服务端，客户端就无法消费且报错，并且binlog日志会丢失
com.alibaba.otter.canal.protocol.exception.CanalClientException: deserializer failed at com.alibaba.otter.canal.client.CanalMessageDeserializer.deserializer(CanalMessageDeserializer.java:54) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.receiveMessages(SimpleCanalConnector.java:322) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.getWithoutAck(SimpleCanalConnector.java:314) at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.getWithoutAck(SimpleCanalConnector.java:286) at com.alibaba.otter.CanalClient.main(CanalClient.java:135)
原提问者GitHub用户MoRongQin
写回答
-
值得去的地方都没有捷径这个问题可能是由于多个客户端同时订阅了同一个Canal服务端，导致消息重复消费以及binlog日志丢失所致。为了避免这种情况发生，建议您采取以下措施：
确保每个客户端都使用唯一的client id。Canal服务端会根据client id来区分不同的客户端，如果多个客户端使用相同的client id，就会导致消息重复消费和binlog日志丢失。
确保每个客户端订阅的表不重复。如果多个客户端订阅了相同的表，就会导致消息重复消费和binlog日志丢失。
确保每个客户端都使用独立的线程来消费消息。如果多个客户端使用相同的线程来消费消息，就会导致消息重复消费和binlog日志丢失。
如果您需要多个客户端同时订阅同一个Canal服务端，建议您使用分布式锁来控制消息消费。这样可以确保每个客户端都能够独立消费消息，避免消息重复消费和binlog日志丢失。
如果您仍然无法解决问题，请尝试升级到最新版本，并检查文档以获取更多信息。如果问题仍然存在，请联系您的技术支持团队进行帮助和支持。
2023-04-28 16:08:12赞同 展开评论 打赏 -
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关文章
相关电子书
更多
