流

Kinesis 流是一组分片，每个分片都是一个有序的记录日志，每个消费者都各自读取每个分片，直到保留期结束。

以文字阅读本图

1. 流 orders: 分片 0; 1; 2; 3; 4; 5; 分片 1; 1; 2; 3; 分片 2; 1; 2; 3; 4
2. 生产者 分区键选定分片 → 流 orders: PutRecord
3. 流 orders → 消费者 billing 每个分片一个迭代器， 每个分片一个检查点: 读取每个分片
4. 流 orders → 消费者 audit 每个分片一个迭代器， 每个分片一个检查点: 读取每个分片
5. 记录为每个读取者保留，直到保留期结束： 默认 24 小时，最长 365 天

生产者用 PutRecord 写入一条记录：流的名称、一个分区键和一个数据块。Kinesis 用 MD5 把分区键哈希成一个 128 位的数字。每个分片拥有这些数字中的一段范围，因此分区键选定分片，同一个键的记录保持顺序。顺序只在分片内部成立，在其他任何地方都不成立。

一条记录只包含一个数据块和一个分区键，此外什么也没有：记录没有消息头。分区键长 1 到 256 个 Unicode 字符，数据块连同分区键最大 10 MiB。流的名称由 1 到 128 个字符组成，可用字母、数字、_、. 和 -。本 crate 用名称指代流。

记录到达时，Kinesis 为它分配一个序列号。在一个分片内部，序列号随时间增长。本 crate 记录分片投递记录的顺序，从不比较序列号本身。

记录一直留在流中，直到保留期结束，不管有没有人读过：默认 24 小时，最长 365 天。每个消费者用自己的迭代器读取每个分片，因此两个消费者都会看到每条记录。消费者读到了哪里，就是每个分片一个位置，即它的检查点。Kinesis 既不保存检查点，也不保存确认：它们由消费者保存在租约表中。

记录里没有存放用户消息头的地方，所以本 crate 把消息头写进载荷前面的一个小信封，并且只在有消息头时才这样做。不带消息头发布的记录就是原样的载荷，任何消费者都能读取。

这一模型就是 Amazon Kinesis Data Streams 自己的模型（关键概念、PutRecord、保留期）。分片如何拆分与合并，见分片与重新分片；消费者如何读取分片，见读取。