0

作为导致大量延迟的重新分片的替代方法,我们如何动态创建 aws kinesis 流并对流进行循环处理

4

1 回答 1

0
  1. 我通过从 twitter 软管鸟客户端获取 2000 年的样本流消息部分解决了这个问题。
  2. 我创建了 3 个 AWS Kinesis Streams,每个都收到 500 条消息并自动调用下一个 AWS Kinesis Stream(java - 代码)。
  3. 对于最后 500 条消息,最后一个流再次称为第一个流。

这是正确的方法吗?

我正在尝试通过书中给出的概念来做到这一点:Galvin 的操作系统概念并将其应用于多个 AWS Kinesis Streams。

于 2015-12-07T11:17:23.887 回答