调用GetShardIterator接口获取读取当前Shard记录的起始iterator。
请求消息结构
message GetShardIteratorRequest {
required string stream_id = 1;
required string shard_id = 2;
optional int64 timestamp = 3;
optional string token = 4;
}名称 | 类型 | 是否必选 | 描述 |
stream_id | string | 是 | 当前Stream的ID。 |
shard_id | string | 是 | 当前Shard的ID。 |
timestamp | int64 | 否 | 根据时间获取ShardIterator，时间单位us。 |
token | string | 否 | 用于分页获取。 |
响应消息结构
message GetShardIteratorResponse {
required string shard_iterator = 1;
optional string next_token = 2;
}名称 | 类型 | 描述 |
shard_iterator | string | 读取当前Shard记录的起始iterator。 |
next_token | string | 获取分片迭代器响应中指示下一个迭代器的标识符。 |
使用SDK
Java SDK：获取Shard的读取迭代值