0

kafka rest proxy指定要获取的记录数。

GET /consumers/(string:group_name)/instances/(string:instance)/records

获取使用订阅/分配 API 之一指定的主题或分区的数据。

此 api 用于从主题中获取记录。是否有一个方便的参数来指定我想要获取的记录数。

例如,我想从某个偏移量中获取 10 条记录。
这个 api 只有两个查询参数,timeoutmax_bytes。没有像limit_num这样的参数。

POST /consumers/(string:group_name)/instances/(string:instance)/positions

覆盖消费者将用于下一组要获取的记录的获取偏移量。

我可以使用这个 api 来设置我想要获取的起始偏移量。

4

1 回答 1

0

没有。

您必须消耗比需要更多的东西,然后提交比您消耗的记录数更低的偏移值

于 2021-11-02T13:48:46.827 回答