我正在尝试使用 Java 中 KCL 库的新功能来实现 AWS Kinesis 的正常关闭,方法是注册关闭钩子以停止所有记录处理器,然后正常停止工作进程。新库提供了记录处理器需要实现的新接口。但它是如何被调用的呢?
尝试先调用worker.requestShutdown(),然后调用worker.shutdown(),它起作用了。但这是使用它的任何预期方式吗?那么两者都有什么用,有什么好处呢?
java aws-java-sdk amazon-kcl amazon-kinesis-firehose
amazon-kcl ×1
amazon-kinesis-firehose ×1
aws-java-sdk ×1
java ×1