Open
Description
alibaba/canal#727
由于云平台数据库会在一定时间后把binlog清理到云存储,导致本地binlog消失,而且binlog越大消失越快。
对于出现位点消费异常导致消费中断,如果修复时间较长会导致恢复后无法继续消费位点的情况,为保证消费连续性,新增PR #741
来实现遇到binlog文件消失时,通过文件下载方法,将binlog文件下载本地解析后再推送给EventHandler处理。
完成自动的离线binlog和在线binlog之间的切换,保证canal消费的连续性。
各云平台可根据自己的API来实现文件下载方法。