问答 2023-05-08 来自:开发者社区

canal实现HA 并且发送消息到kafka集群,主备切换导致消息重复发送

canal实现HA后,binlog的position记录到了zookeeper中,但将主应用暂停掉后,备用会将之前一段时间没有经由它处理的binlog重新投递到kafka中.是什么情况??? 在HA模式下 停止A,切换到B,再启动A,再停止B由A操作的zk上的cursor的position不更新,不知道是因为集成了Kafka还是其他原因?? 原提问者GitHub用户ViberW

问答 2023-05-04 来自:开发者社区

HA模式下Kafka事务失败

单机模式,Canal能够正常执行Kafka Transactional,但是多台HA的时候报错如下: Producer attempted an operation with an old epoch. Either there is a newer producer with the same transactionalId, or the producer's transaction has....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等