我们在google云上开发了一个微服务架构。实际上，这些微服务都是在云上运行的，它们通过rest（sync）或pub/sub（async）运行并相互通信。
它是一种事件驱动模式，因此当服务在右侧的pub/sub主题上发布某个事件（如“user\u created”）时，许多服务在其http端点上通过推送订阅接收该事件。
现在，我们将移动到Kafka的消息排序和重放功能。不幸的是，kafka消费者是基于pull的，所以我们需要改变服务接收事件的方式。
因为CloudRun是一个无服务器的解决方案，可以扩展到零，所以我们不能让它听kafka的主题，因为服务可能会在夜间关闭，因为没有请求到达。
我们有不同的服务，可以安全地用一个预定的cron更新，因此每一个小时作为示例，我们向服务发出一个get请求，该请求下载所有新的kafka消息并相应地更新自身。
但是许多其他服务需要一个近乎实时的更新来完成它们的角色。
那么，在这种架构下，谷歌云平台的哪个产品最适合消费Kafka主题呢？
谢谢！