数据流作业消耗未结束，系统延迟长时间增长

Question

我们有一个以任一结尾的数据流管道

• 向“完成”主题发送 PubSub 消息或

• 向“DLQ”或“RETRY”主题发送 PubSub 消息

这是数据管道的图表：

这是系统延迟问题，尽管所有 6 个元素都已成功处理：

对于我们在两个主题上都发送了一些消息的情况，数据流无法识别成功结束并且系统延迟增加并且排空卡住了！

Answer 1

我们发现该事件发生在您错过发布/订阅主题时，特别是在我们的案例中，忘记创建 DLQ 主题。