Mad*_*aks 6 stream amazon-web-services amazon-kinesis
我对 Kinesis Streams 还很陌生,花了很多时间翻阅文档,但无法确定单个分片上是否可以有多个“主题”(由于缺乏更好的术语)。最初我认为这就是分区键的用途,但是读完后:
分区键用于按流中的分片对数据进行分组。Streams 服务将属于流的数据记录分为多个分片,使用与每个数据记录关联的分区键来确定给定数据记录属于哪个分片。
...在我看来,分区(可以)跨越多个分片。
我目前不需要多个分片,但我确实需要能够将消息分离到该分片内的不同通道/主题中 - 这对于 Kinesis 来说不可能吗?
- 编辑 -
值得一提的是,我在我的应用程序中同时使用了 KCL 和 KPL。
仅使用单个分片,您将无法将数据分离到单独的通道中。要使用记录,您必须首先调用 GetShardIterator。GetShardIterator 获取流名称、分片 ID 和迭代器类型。
返回的分片迭代器是指向流的指针。如果您调用 GetRecords,并传入分片迭代器,Kinesis 会将记录返回给您。响应将包含一批记录,包括数据、时间戳、序列号和分区键。
目前,在调用 GetRecords/GetShardIterator 时无法指定主题或任何其他过滤器。
| 归档时间: |
|
| 查看次数: |
4236 次 |
| 最近记录: |