Amazon Kinesis 动态流调整大小

Question

我正在研究 Amazon Kinesis Api 和 Kinesis Client 库，我创建了一个生产者来将数据放入流中，并有多个消费者应用程序从该流中读取数据。

我有根据输入流大小和输出流大小以及使用消费者应用程序的计数动态增加和减少流大小的方案。

我从亚马逊网站上找到了一些有用的来源来计算碎片的数量，但不知道如何计算。源 URL 是：http : //docs.aws.amazon.com/kinesis/latest/dev/how-do-i-size-a-stream.html

需要对此有所了解。

谢谢

Answer 1

AWS 支持建议查看以下开源项目。它是由他们的一位解决方案架构师创建的。

https://github.com/awslabs/amazon-kinesis-scaling-utils

它可以手动 (cli) 或自动运行（部署的 WAR）来扩展/缩小您的应用程序。