Spring 集成 AWS Kinesis 消息处理程序

Question

KinesisMessageHandler class 接受输入为 AmazonKinesisAsync 的构造函数。 AmazonKinesisAsync 是一个用于异步访问 Kinesis 的接口。这是否意味着 KinesisMessageHandler 没有同步支持？

另外，KinesisMessageHandler 中的 setSync 方法有什么相关性？

Answer 1

AmazonKinesisAsync 实际上只是依赖于 Java 的 Future，它可以通过其 get() 方法轻松转换为同步、阻止行为。这就是 setSync() 在 KinesisMessageHandler 状态下的目的。将 AmazonKinesisAsync 作为输入并不意味着我们不能进行同步操作。如果我们对 AmazonKinesis 合约有相反的要求，我们将无法执行异步操作。