我想每秒向KAFKA中插入大约500k的数据,然后将它们与每秒仅支持40k插入/更新的MySQL数据库同步。
因此,为了实现我的目标,我想使用KAFKA作为热存储,因为我需要尽可能快地使用数据,并与多个服务共享它们,并快速进行更新,因为它不能单独使用MySQL (我想将其用作冷存储,以尽可能长地存储数据并存档更改)。
这里有一个关于我的需求的模式:https://i.imgur.com/NyRn8zi.jpg
有没有关于如何处理这个案子的想法?或者用另一种方式来达到同样的目标?
我不需要代码,只需要资源和路径(我的主要语言是PHP)。
发布于 2019-06-20 10:19:29
Kafka connect JDBC既充当源,又充当。因此,它至少可以执行插入,并且更新可能取决于表中的Kafka消息结构/主键
https://stackoverflow.com/questions/56675206
复制相似问题