经常出现deserializer failed的错误，canalserver,canaclient版
经常出现deserializer failed的错误，canalserver,canaclient版本均为1.1.2,这是什么原因呢。
2019-02-21 15:23:05 | ERROR - main - com.alibaba.otter.CanalClient - connector.rollback batchId==5972 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) Caused by: com.alibaba.otter.canal.protocol.exception.CanalClientException: something goes wrong with reason: something goes wrong with channel:[id: 0x5c108217, /192.168.2.201:48051 => /172.20.0.2:11111], exception=com.alibaba.otter.canal.server.exception.CanalServerException: ack error , clientId:1001 batchId:5972 is not exist , please check
at com.alibaba.otter.canal.client.CanalMessageDeserializer.deserializer(CanalMessageDeserializer.java:46) ... 4 more
原提问者GitHub用户uther518
写回答
-
ack error , clientId:1001 batchId:5972 is not exist , please check
应该是这个问题，估计server端发生了rollback
原回答者GitHub用户agapple
2023-05-09 17:55:29赞同 展开评论 打赏 -
随心分享，欢迎友善交流讨论：）这个错误通常是因为CanalClient和CanalServer之间的网络连接中断或者CanalServer内部出现了异常导致的。CanalClient在接收到CanalServer的数据时，需要先对数据进行反序列化，如果反序列化失败，就会抛出CanalClientException异常。这时，需要先检查一下CanalClient和CanalServer之间的网络连接是否正常，以及CanalServer是否正常工作。如果网络连接正常，可以检查CanalServer的日志，查看是否有异常信息。此外，由于CanalServer的异常也可能导致反序列化失败，因此，建议在CanalServer中实现自定义的ErrorHandler来捕获异常并进行处理，以避免异常被吞掉而导致反序列化失败。可以参考以下代码来实现ErrorHandler：
public class CustomErrorHandler implements ErrorHandler {
private static final Logger logger = LoggerFactory.getLogger(CustomErrorHandler.class); @Override public void onError(Throwable throwable) { logger.error("CanalServer error: {}", throwable.getMessage()); // do something... }} 然后，在CanalServer的配置文件中添加以下配置：
canal.server.errorHandler = com.foo.CustomErrorHandler 这样，在CanalServer出现异常时，就会被ErrorHandler捕获并进行处理，从而避免了反序列化失败。
2023-05-08 15:24:01赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
