amazon-kcl - 如何在 Java 中暂停 KCL 客户端

Question

我们有一个 Spring 应用程序，它使用 Java KCL 客户端来使用 Kinesis 流中的记录。有没有办法我们可以以某种方式“暂停”KCL 以停止处理记录，然后稍后安全地重新启动它？推荐的方法是什么？

Answer 1

没有停止和重新启动工作程序的机制。作为一种解决方法，当您想再次开始处理记录时，您可以调用 worker.shutdown() 并创建一个新的工作人员。请注意，您还需要在 AmazonDynamoDBStreamsAdapterClient 上调用 shutdown()。仅关闭工作器不会阻止 KCL 处理记录。