什么是ClusterMessage接口
每个ClusterMessage保存RDS中的一个事务的数据记录，事务中的每条记录通过Record保存，本小节介绍ClusterMessage的主要接口函数。
Record getRecord()
这个接口从ClusterMessage中获取一条变更记录。这个变更记录表示RDS binlog文件中的每一条记录，例如begin ,commit,update,insert等。
void ackAsConsumed
为了简化下游SDK进程容灾，数据订阅服务端支持SDK的消费位点保存，当下游SDK异常宕机并重启后，会自动从上次异常退出的最后一个消费位点继续订阅并消费数据。
在message消费完成后，需要调用这个接口向数据传输服务端汇报一个ACK，通知服务端更新下游SDK的消费位点, 保证SDK异常重启后消费数据的完整性。
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
