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

一个事务,却被拆分成多条消息(KAFKA)

canal 版本v.1.1.5 当配置canal.mq.flatMessage = true时(json) 一个事务(比如两条更新语句),会生成两条消息(in kafka), 不正常! 当配置canal.mq.flatMessage = false时(pb) 一个事务(比如两条更新语句),只会生成一条消息(in kafka),正常! 原提问者GitHub用户tomas-tu

文章 2022-06-13 来自:开发者社区

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)

就是来了波狸猫换太子,其实延时消息也是这么实现的,最终将换了皮的消息入盘。Broker 处理提交或者回滚消息的处理方法是 EndTransactionProcessor#processRequest,我们来看一看它做了什么操作。可以看到,如果是提交事务就是把皮再换回来写入真正的topic所属的队列中,供消费者消费,...

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(下)
文章 2022-06-13 来自:开发者社区

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

每个时代,都不会亏待会学习的人。大家好,我是 yes。今天我们来谈一谈消息队列的事务消息,一说起事务相信大家都不陌生,脑海里蹦出来的就是 ACID。通常我们理解的事务就是为了一些更新操作要么都成功,要么都失败,不会有中间状态的产生,而 ACID 是一个严格的事务实现的定义,不过在单体系...

消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?(上)

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注