开发者社区> 问答> 正文

关于group模式,zookeeper更新cursor的问题

canal版本1.14 在测试分库时,用gorup模式,两个mysql实例。zookeeper上的路径/otter/canal/destinations/coupon/1001/cursor是交替更新的。意味着只能记录一个位点。

在canal重启时, 在zk上记录有位点的binlog没问题,但没有记录的会重复的消费一条。

canal instance的数据库配置:

canal.instance.master1.address=10.204.245.46:3306 canal.instance.master1.journal.name= canal.instance.master1.position= canal.instance.master1.timestamp= canal.instance.master1.gtid=

canal.instance.master2.address=10.204.245.46:3307 canal.instance.master2.journal.name= canal.instance.master2.position= canal.instance.master2.timestamp= canal.instance.master2.gtid=

canal的的metaManager配置:

<bean id="metaManager" class="com.alibaba.otter.canal.meta.PeriodMixedMetaManager">
	<property name="zooKeeperMetaManager">
		<bean class="com.alibaba.otter.canal.meta.ZooKeeperMetaManager">
			<property name="zkClientx" ref="zkClientx" />
		</bean>
	</property>
	<property name="period" value="${canal.zookeeper.flush.period:1000}" />
</bean>

解析位点配置:

原提问者GitHub用户shizhengchao

展开
收起
数据大拿 2023-05-04 11:04:25 97 0
1 条回答
写回答
取消 提交回答
  • group模式不建议生产使用

    原回答者GitHub用户agapple

    2023-05-05 10:09:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
《MSE 微服务网关》 立即下载
微服务引擎 MSE 治理中心重磅发布 立即下载
阿里云微服务引擎 MSE 2.0 线上发布 立即下载