Kafka REST Proxy拉取记录是否支持指定返回数量参数查询

首先明确：原生Kafka REST Proxy的GET /consumers/{group_name}/instances/{instance}/records接口没有提供直接指定返回记录条数的请求参数，仅支持你提到的timeout和max_bytes两个查询参数，这是因为Kafka底层消费者的拉取逻辑默认是按字节阈值、超时时间控制拉取批次，没有按条数优先的原生设计。

你已经掌握了通过POST /consumers/{group_name}/instances/{instance}/positions接口设置起始拉取offset的方法，在此基础上要实现拉取指定条数记录，可以用以下两种方案：

方案1：客户端侧处理（通用场景推荐） #

这是最便捷、不需要修改服务端的实现方式：

• 先调用POST /consumers/{group_name}/instances/{instance}/positions接口设置好目标起始offset
• 调用拉取接口时，根据单条消息的平均大小设置max_bytes，比如你要拉取10条、单条消息平均大小为1KB的话，可以把max_bytes设为102400（留足冗余，避免单条消息超过阈值无法返回），timeout设为3000~5000ms的合理值
• 拿到接口返回的消息数组后，直接截取前N条即可；如果单次返回的条数不足你需要的数量，可以重复调用拉取接口，直到凑够指定条数，或者达到你自定义的超时重试上限
• 拉取完成后如果不需要继续消费，可以手动提交offset避免后续重复消费。

方案2：服务端二次开发（仅适合有定制需求的场景） #

如果你们团队有对Kafka REST Proxy做二次开发的权限，可以在服务端拉取逻辑中新增自定义的条数限制参数，在服务端攒够指定条数后再返回结果。但该方案需要维护自定义的服务端版本，后续官方版本升级适配成本较高，非必要不推荐使用。

附相关接口说明：
GET /consumers/(string:group_name)/instances/(string:instance)/records
通过subscribe/assign系列API拉取指定主题或分区的数据。

POST /consumers/(string:group_name)/instances/(string:instance)/positions
覆盖消费者下一批拉取记录将要使用的fetch偏移量。

内容的提问来源于stack exchange，提问作者niaomingjian