在数据库和Kafka生产者之间同步事务

作者: 狗头军师
发布时间: 2024-02-21 11:13:06 (2月前)

2 条回复

1#
回复此人
v-star*위위 | 2020-08-12 15-06

我建议使用方法2稍有改动的变体。仅写入数据库，但除了实际的表写入之外，还将“事件”写入同一数据库内的特殊表中；这些事件记录将包含您需要的汇总。以最简单的方式，您只需插入另一个实体（例如，由JPA映射），该实体包含带有聚合有效负载的JSON属性。当然，这可以通过某种方式的事务侦听器/框架组件来自动化。然后使用Debezium仅从该表中捕获更改，并将其流式传输到Kafka。这样，您就可以兼得：最终在Kafka中保持一致的状态（Kafka中的事件可能会落后或重新启动后第二次可能会看到一些事件，但最终它们会反映数据库状态），而无需进行分布式事务，以及您追求的业务级别事件语义。（免责声明：我是Debezium的负责人；很有趣的是，我只是在撰写一篇博客文章，详细讨论这种方法）这是帖子 https://debezium.io/blog/2018/09/20/materializing-aggregate-views-with-hibernate-and-debezium/ https://debezium.io/blog/2019/02/19/reliable-microservices-data-exchange-with-the-outbox-pattern/

编辑

登录后才能参与评论