【发布时间】:2021-11-05 03:22:58
【问题描述】:
kafka rest proxy 指定要获取的记录数。
GET /consumers/(string:group_name)/instances/(string:instance)/records
使用订阅/分配 API 之一为指定的主题或分区获取数据。
这个 api 用于从主题中获取记录。是否有一个方便的参数来指定我想要获取的记录数。
例如,我想从某个偏移量获取 10 条记录。
这个api只有两个查询参数,timeout和max_bytes。
没有像 limit_num 这样的参数。
POST /consumers/(string:group_name)/instances/(string:instance)/positions
覆盖消费者将用于下一组要获取的记录的获取偏移量。
我可以使用这个api来设置我想要获取的起始偏移量。
【问题讨论】:
标签: apache-kafka confluent-platform kafka-rest