Google Cloud(GCP)发布/订阅支持的功能是否类似于Kafka中的ConsumerGroups

尝试在Google Cloud(GCP)发布/订阅与管理器Kafka服务之间做出选择。

在最新更新中,发布/订阅添加了对重放以前处理过的消息的支持,这是一个受欢迎的更改。

我在他们的文档中找不到的一个功能是,我们是否可以拥有类似于Kafka的消费者组的东西,即拥有一组订户,并且每个组都处理同一主题的数据,并且能够重新处理来自开始于某些订户(消费者组),而其他订户不受此影响。 例如:

让我们说您有一个主题作为股票提示

您有两个消费群体

CG1:具有两个 subscriptions 消费者
CG2:还有另外两个 subscriptions 消费者

在Kafka中,我可以独立地在这些组之间阅读消息,但是我可以对Pub / Sub做同样的事情。

Kafka允许您从头开始重播消息,我可以对Pub / Sub进行同样的操作,如果我无法重播创建CG之前发布的消息,可以,但是可以重播该消息吗?是在创建CG /订户之后提交的?

heyu193 回答:Google Cloud(GCP)发布/订阅支持的功能是否类似于Kafka中的ConsumerGroups

Cloud Pub / Sub等同于Kafka的消费者组是订阅。订户相当于消费者。 This answer详细说明了订阅和订阅者之间的关系。

您在Cloud Pub / Sub术语中的示例将有一个主题,即StockTicks,具有两个订阅(称为CG1和CG2)。您将带出四个订阅者,两个订阅者为订阅CG1获取消息,两个订阅者为CG2订阅获取消息。调用和重播将独立于CG1和CG2,因此,如果您要查找CG1,则完全不会影响向CG2的订户传递消息。

请记住,使用Cloud Pub / Sub,只有在成功创建订阅后发布的消息才会传递给该订阅的订阅者。因此,如果您创建一个新的订阅,您将无法获得自时间开始以来发布的所有消息。从那时起,您只会收到发布的消息。

如果您寻求订阅,则最多只能重播7天的消息(假设订阅至少是在7天之前创建的),因为这是Cloud Pub / Sub中消息的最大保留时间。

本文链接:https://www.f2er.com/3100417.html

大家都在问