当前位置: 首页 > 知识库问答 >
问题:

如何在Java中暂停KCL客户端

丌官博文
2023-03-14

我们有一个Spring应用程序使用JavaKCL客户端从Kinesis流中消费记录。有没有办法让KCL“暂停”以停止处理记录,然后安全地重新启动它?对此推荐的方法是什么?

共有1个答案

韩宜春
2023-03-14

没有停止和重新启动工作进程的机制。作为一种变通方法,你可以打电话给工人。shutdown()并在您想再次开始处理记录时创建一个新的工作进程。请注意,您还需要在AmazondynamodBStreamAdapterClient上调用shutdown()。仅关闭工作人员不会阻止KCL处理记录。

 类似资料:
  • 我的目标是暂停录制文件。我在Android开发者网站上看到了它的但Media Recorder并没有暂停选项。 Java支持以编程方式合并两个音频文件,但在android中不起作用。 从Java中加入两个WAV文件? 而且我还使用了默认设备录音机应用程序,该应用程序适用于所有设备,但在三星中,很少有设备没有返回录制路径。 任何一个帮助语音录音暂停功能。

  • 我试图实现一个播放/暂停按钮,用于连接到ARKit场景中节点的位置音频。我希望用户能够暂停音频,然后在以后的时间从暂停点恢复它。因此不好,因为这会在重新连接音频时将其重置到起始位置。 我能找到的唯一与SCNAudioPlayers相关联的暂停方法深藏在下面: 有人知道这能不能做到吗? 提前谢了。

  • 为什么我发现KCL与AWS Lambda一起使用的例子如此之少。https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-kcl.html 它确实提供了一个很好的实现来跟踪您在流中的位置(检查点)。 我想使用KCL作为消费者。我的设置是一个具有多个碎片的流。每个碎片上都有一个Lambda在消耗。我想使用Lamb

  • 问题内容: 在Spring Framework手册中,它们声明对于PROPAGATION_REQUIRES_NEW,当前事务将被挂起。 那“暂停交易”是什么?超时计时器停止指望当前事务吗?这种暂停的实际含义是什么? 谢谢, 问题答案: 这并不意味着什么特别的事情,挂起的事务只是暂时不用于插入,更新,提交或回滚的事务,因为由于指定的传播属性应创建一个新事务,并且只能激活一个事务同时。 基本上有两种事

  • 抱歉我的问题,我被卡住了。我是lib gdx开发游戏的新手,不要严格评判我。我有我的游戏活动: } 我有两个屏幕: 还有我有暂停按钮的游戏屏幕: 还有我的主要问题--

  • 我正在寻找一个解决方案,以暂停从应用程序本身的kinesis流的消息消费时,下游服务关闭。我正在使用Spring-云-流-绑定器-动力。这样做没有明显的选择。在KCL api上似乎也没有一个选项。在Spring执行器绑定endpoint上有停止/暂停,这似乎对Kinesis不起作用。一种选择是使用AWS SDK api,并执行一个拉机制而不是KCL/Spring cloud的推机制,并停止拉断路器