微服务数据复制模式

有两种选择:

1. 您可以为单个主题启用Kafka的日志压缩。它将保留给定密钥的最新值以丢弃旧更新。这样可以节省空间,并且在给定的保留期内比正常模式保存更多的数据

2. 假设您每天备份服务B DB,在引入新的服务C时,您需要首先从B的最新备份创建C的初始状态,然后从表示备份后数据的特定偏移id重播Kafka主题事件。

你的担心是对的,但同时微服务的方法是给予和接受。您将以每个服务的单个数据库为代价获得松耦合。微服务体系结构没有正确的答案,这取决于您要实现的目标。

根据CAP定理,您必须在一致性和可用性之间做出折衷,在大多数情况下,我们采用最终一致性。如果你的服务A与B不一致,那么它最终将是,这是以可用性为代价的权衡。

对于后期加入系统的新服务,事件源是用于此类场景的模式。它的复杂模式,但它会将新添加的服务带到您希望它们处于的状态。基本上,您将所有事件保存在一个事件存储中并重播它们,以获得系统的当前状态,并用这些事件预填充ServiceC数据库。