首页 > 解决方案 > 使用 mongodb 和 kafka 消费者的并发更新问题

问题描述

我有一个包含 4 个 kafka 消费者的应用程序,它们正在对 mongodb 进行更新操作。他们可能会尝试同时更新相同的记录。我已经使用同步块处理它进行更新。当我在单个服务器上运行应用程序时,它工作正常。但是当我在多台服务器上运行此应用程序以实现高可用性时,它会失败。并且某些事务无法更新记录,因为它们已获取相同状态的记录。任何人都可以提出正确的方法来做到这一点。谢谢。

标签: mongodbapache-kafkakafka-consumer-api

解决方案


推荐阅读