从 PubSubIO 读取：fromTopic 与 fromSubscription

Question

我在一些示例代码中看到似乎直接从主题中读取？

PubsubIO.readStrings().fromTopic(fullTopic))

那和有区别吗

PubsubIO.readStrings().fromSubscription(fullTopic))

（我一直觉得你必须订阅一个主题......）

编辑：使用 fromTopic添加到示例的链接

Answer 1

是的，存在差异。请注意，该fromSubscription方法采用订阅路径，而不是主题路径。如果使用fromTopic，则将创建一个新订阅。因此，在代码运行之前发布的任何消息都不会被读取。每次代码运行时，都会最终创建一个新订阅。

相反，fromSubscription使用现有订阅，这意味着在创建订阅后任何时间发布的消息都将被读取。如果作业停止并重新启动，那么读取可以从停止的地方继续。