为 Google PubSub 暂停 Spring Cloud StreamListener

Question

我们使用 Spring Cloud Stream（版本 3.0.7）StreamListener 从主题“A”的 Google 云 PubSub 订阅“A.SUB”中消费。 我们需要暂停 PubSub 的消费，我按偏好顺序查看以下选项，我不知道如何实现选项 1 和 2。有人可以分享一下这些想法吗？

1. 添加另一个 Pubsub 主题“B”并发布“暂停”事件消息以暂停或“恢复”事件消息以恢复，在看到“暂停/恢复”时以某种方式停止/启动订阅“A.SUB”的轮询器 有什么方法可以实现吗？

2. 根据时间窗口暂停订阅，比如上午 12 点到 6 点之间？有没有办法指定一些 CRON 表达式？

3. 在 12AM 和 6AM 之间使用来自“A.SUB”的消息并发送 nack

@StreamListener("A.SUB") 公共无效消费（消息消息）{}

Answer 1

注意：StreamListener 和整个基于注解的配置模型已被弃用。我们已经完全迁移到functional programming model，这要简单得多。

关于暂停，您可以通过 s-c-stream 公开的执行器和绑定端点（例如，停止、启动、暂停、恢复）来完成它。您可以通过here获取更多信息。