我正在研究 Amazon Kinesis Api 和 Kinesis Client 库,我创建了一个生产者来将数据放入流中,并有多个消费者应用程序从该流中读取数据。
我有根据输入流大小和输出流大小以及使用消费者应用程序的计数动态增加和减少流大小的方案。
我从亚马逊网站上找到了一些有用的来源来计算碎片的数量,但不知道如何计算。源 URL 是:http : //docs.aws.amazon.com/kinesis/latest/dev/how-do-i-size-a-stream.html
需要对此有所了解。
谢谢