如何暂停用户在spring cloud kinesis流中使用消息
我正在寻找一个解决方案，以暂停从应用程序本身的kinesis流的消息消费时，下游服务关闭。我正在使用Spring-云-流-绑定器-动力。这样做没有明显的选择。在KCL api上似乎也没有一个选项。在Spring执行器绑定endpoint上有停止/暂停，这似乎对Kinesis不起作用。一种选择是使用AWS SDK api，并执行一个拉机制而不是KCL/Spring cloud的推机制，并停止拉断路器。
这样做还有其他选择吗？
共有1个答案
Kinesis使用者（独立于库）根本不支持暂停/恢复。AWS Kinesis中没有这样的概念。
您确实可以使用start/stop执行器endpoint来控制特定绑定的生命周期。
不确定你为什么说它不起作用：这部分与其他粘合剂没有区别。
-
我使用的是spring引导版本1.3.2。我正在使用@JMSListener从activemq获取我使用JMSTemplate创建/生成的消息。代码如下： 现在当从smtp出现连接失败错误时，我想暂停@JMSListener一段时间，然后重新开始使用消息。对于这个用例，我还没有看到使用@JMSListener的更好的例子。由于我使用的是spring boot，我在应用程序属性中添加了activem
-
我们有一个Spring应用程序使用JavaKCL客户端从Kinesis流中消费记录。有没有办法让KCL“暂停”以停止处理记录，然后安全地重新启动它？对此推荐的方法是什么？
-
我正在从数据库中提取数据，以检查我是否有可用的系统资源来处理来自KafkaListener的进一步消息。如果我的条件没有满足，那么我希望@KafkaListener暂停，当条件满足时，我希望@KafkaListener恢复。我如何在SpringKafka实现这一点？ 另外，为特定分区暂停消费者有什么缺点吗？
-
我的目标是暂停录制文件。我在Android开发者网站上看到了它的但Media Recorder并没有暂停选项。 Java支持以编程方式合并两个音频文件，但在android中不起作用。 从Java中加入两个WAV文件？ 而且我还使用了默认设备录音机应用程序，该应用程序适用于所有设备，但在三星中，很少有设备没有返回录制路径。 任何一个帮助语音录音暂停功能。
-
可能会有暂停应用的需求，那这里给做了一个。 实现非常简单，就是对容器的启动使用做了一个Sleep 当然还有另一种方案是将 replace 设置为 0
-
问题内容： 谁能帮助我如何使用Selenium自动播放/暂停网页上显示的视频。 提前致谢… 问题答案： 这在很大程度上取决于浏览器和处理视频的播放器。您很有可能需要使用JavaScript执行程序。 我昨晚与一位朋友讨论了这个问题，他提出了以下示例，该示例使用了Webdriver的Python变体，用于html5demos.com的演示视频： 您也可以在使用“播放”的地方“暂停”。 这里有一个更大