问题描述
我们在Google云上开发了微服务架构。 实际上,所有微服务都在云上运行,并与其余(同步)或与pub / sub(异步)对话。
这是事件驱动的模式,因此,当服务在正确的发布/订阅主题上发布了某件事(例如“ user_created”)时,许多服务会在其http上订阅 push 来接收该事件。端点。
现在,我们将迁移到kafka以获得消息订购和重播功能。 不幸的是,kafka消费者是基于拉动的,因此我们需要更改服务接收事件的方式。
由于云运行是可扩展至零的无服务器解决方案,因此我们无法使其监听kafka主题,因为该服务可能会在夜间由于没有请求到达而关闭。
我们有不同的服务,可以使用计划的cron安全地进行更新,因此,例如,每隔1个小时,我们就会收到一个服务请求,该请求会下载所有新的kafka消息并进行相应的更新。
但是许多其他服务需要近乎实时的更新才能发挥作用。
那么哪种Google Cloud Platform产品最适合在此架构中使用kafka主题?
谢谢!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)