We have a dataflow process subscribed to "Subscribtion A" on a "Topic A" processing messages in streaming mode.
我们在流媒体模式下处理消息的“主题A”上订阅了“订阅A”的数据流过程。
According to PubSub documentation, if the messages are not pulled they will be retained for at least 7 days per subscription. Am I right to assume that if I stop my Dataflow process for an hour and then restart, it should process all the messages accumulated in the subscription while subscriber process was down before proceeding with the streaming messages?
根据PubSub文档，如果消息未被提取，则每次订阅将保留至少7天。我是否正确地假设如果我停止我的数据流进程一小时然后重新启动，它应该处理订阅中累积的所有消息，而订阅者进程在继续流式消息之前停止？
In our case Dataflow process does not seem to pick up queued messages after restart. Is there any explicit configuration option that we are missing?
在我们的例子中，Dataflow进程似乎在重新启动后没有获取排队的消息。我们缺少任何明确的配置选项吗？
1 个解决方案
#1
1
We tested it again and it does seem to work fine. It appears to be related to some other issues.
我们再次测试它似乎工作正常。它似乎与其他一些问题有关。
#1
1
We tested it again and it does seem to work fine. It appears to be related to some other issues.
我们再次测试它似乎工作正常。它似乎与其他一些问题有关。