Tag: amazon kinesis firehose

对于AWS Kinesis的KCL Java库，如何使用requestShutdown和shutdown来执行正常关闭

我正在尝试使用Java中的KCL库的新function来为AWS Kinesis通过注册shutdown hook来优雅地关闭以停止所有记录处理器，然后优雅地停止工作。 新库提供了一个新的接口，需要实现记录处理器。 但它是如何被调用的？ 尝试首先调用worker.requestShutdown（）然后调用worker.shutdown（）并且它可以正常工作。 但是它是否有任何预期的使用方式。 那么使用它们有什么用处，它的好处是什么？