canal.deployer使用rabbitmq重启后position丢失?

ykejflvf  于 2个月前  发布在  RabbitMQ
关注(0)|答案(2)|浏览(42)

因为主库socket断掉,清理了canal-deployer/conf/example/meta.data文件

Question

在canal-deployer/conf/example/instance.properties配置文件中配置如下:

canal.instance.master.journal.name=mysql-bin.000001
canal.instance.master.position=260675340

启动canal.deployer一段时间后

查看目录canal-deployer/conf/example/meta.data

{"clientDatas":[{"clientIdentity":{"clientId":1001,"destination":"example","filter":""},"cursor":{"identity":{"slaveId":-1,"sourceAddress":{"address":"xxxx","port":3306}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000001","position":45019805,"serverId":1,"timestamp":1668737059000}}}],"destination":"example"}

未执行到配置文件中的点位,塞了好多配置文件之前的点位数据。

不是应该只塞配置文件之后点位的数据吗?这样子删除meta.data重启deployer之后,会产生大量配置文件点位之前的数据。求助各位大神,能否rabbitmq里面只加入配置点位之后的数据?

2skhul33

2skhul331#

你们是不是发错了?…

------------------ 原始邮件 ------------------ 发件人: ***@***.***>; 发送时间: 2022年12月6日(星期二) 下午4:37 收件人: ***@***.***>; 抄送: ***@***.***>; 主题: [alibaba/canal] canal.deployer使用rabbitmq重启后position丢失? (Issue #4517) 因为主库socket断掉,清理了canal-deployer/conf/example/meta.data文件 Question 在canal-deployer/conf/example/instance.properties配置文件中配置如下: canal.instance.master.journal.name=mysql-bin.000001 canal.instance.master.position=260675340 启动canal.deployer一段时间后 查看目录canal-deployer/conf/example/meta.data {"clientDatas":[{"clientIdentity":{"clientId":1001,"destination":"example","filter":""},"cursor":{"identity":{"slaveId":-1,"sourceAddress":{"address":"xxxx","port":3306}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000001","position":45019805,"serverId":1,"timestamp":1668737059000}}}],"destination":"example"} 未执行到配置文件中的点位,塞了好多配置文件之前的点位数据。 不是应该只塞配置文件之后点位的数据吗?这样子删除meta.data重启deployer之后,会产生大量配置文件点位之前的数据。求助各位大神,能否rabbitmq里面只加入配置点位之后的数据? — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you are subscribed to this thread.Message ID: ***@***.***>

kx5bkwkv

kx5bkwkv2#

没有发邮件 只提的一个issue question @graphic-programmer

相关问题