为何Pub/Sub快照恢复的消息到达Topic后未被Dataflow流水线消费

• 你为Dataflow绑定的Pub/Sub订阅开启了消息去重功能，重发的消息message_id和一周前原始消息的message_id完全一致，Pub/Sub会将其判定为重复消息直接过滤，不会推送给订阅方。
• 重发快照时误用了seek到快照的操作，但操作仅作用于测试用的其他订阅，未修改Dataflow实际绑定的生产订阅的消费游标，生产订阅没有回退到快照对应的历史位置，自然不会消费到快照内的消息。
• 修复Bug后重启Dataflow流水线时，你选择了从最新偏移量启动的配置，流水线默认只拉取启动时间点之后生成的新消息，重发的历史消息属于启动前的旧消息，不会被拉取处理。
• Dataflow绑定的Pub/Sub订阅配置了消息过滤规则，重发的消息属性刚好匹配过滤排除规则，被Pub/Sub主动拦截不会下发给流水线。
• 你将快照消息重发到了同名但所属项目、区域不同的测试Topic，实际对接Dataflow的生产Topic并未收到这些重发消息，导致流水线无消息可消费。
• Dataflow的Pub/Sub源配置了最早消息时间戳阈值，时间戳早于该阈值的消息会被流水线直接丢弃，一周前的历史消息时间戳低于阈值，被主动过滤没有进入处理逻辑。
• 重发快照期间Dataflow流水线处于暂停、异常崩溃的不可用状态，待流水线恢复正常运行时，重发的消息已经超过了订阅设置的消息保留期限，被Pub/Sub自动清理无法再被消费。

内容的提问来源于stack exchange，提问作者gecaro