CanalRocketMQClientExample中空指针问题
CanalRocketMQClientExample#process中，如果connector.getListWithoutAck()第一次返回的messages大小为0，则RocketMQCanalConnector中的lastGetBatchMessage仍未null，后续调用connector.ack()时会抛空指针。
原提问者GitHub用户ymwneu
写回答
-
b6f1e0d：https://github.com/alibaba/canal/commit/b6f1e0d13c4feb3e93a200688008dad4e5cf6b07
原回答者GitHub用户agapple
2023-05-09 18:43:39赞同 展开评论 打赏 -
随心分享，欢迎友善交流讨论：）你提出的问题可能确实存在，如果connector.getListWithoutAck()第一次返回的messages大小为0，则RocketMQCanalConnector中的lastGetBatchMessage确实仍未null，后续调用connector.ack()时可能会抛空指针异常。
解决这个问题的方法是在调用connector.ack()之前，先判断一下lastGetBatchMessage是否为null，如果为null，则不进行ack操作。可以在CanalRocketMQClientExample的process方法中加入以下代码段：
if (lastGetBatchMessage != null) { connector.ack(lastGetBatchMessage.getId()); } 这样就可以避免空指针异常的问题了。
2023-05-08 17:52:07赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
