go - Nack 消息并选择重新投递时间
问题描述
有没有办法接收消息并告诉 pubsub 后端在 X 秒内重新发送它?
我不是在寻求全局重试策略,因为我知道订阅具有指数退避重试选项,我正在寻找一种方法来指示在 X 秒内重新传递一条消息。
解决方案
正如其他评论者所指出的,在 Cloud Pub/Sub 中没有针对单个消息执行此操作的内置方法。如果您希望在 X 秒内重新传递消息,则需要将其 ack 截止日期延长 X 秒,然后将其 nack(这将触发重新传递)。
推荐阅读
- java - @kafkaListener 的范围
- amazon-web-services - 停止并重新启动后,无法通过 Web 浏览器访问 EC2 实例上的 Jupyter Lab
- python - 当我在 pydriod 3 应用程序上运行 python manage.py runserver 时找不到模板
- google-cloud-platform - GCP 监控代理不断增加内存使用量
- rust - 使用正确的(特定于目标的)编译器链接到外部对象
- python - 如何可视化最近的加密交换订单
- flutter - 使用 Get.put 在 Flutter 中创建类的实例
- r - 如何将 Web of Science 高级查询变成 R 中的正则表达式?
- sass - “粗鲁。” 未被识别为内部或外部命令、可运行程序或批处理文件
- react-native - NPM 卡在理想树上:定时理想树