一次性调用的kafka消费者轮询方法的行为

【问题标题】：behavior of kafka consumer poll method with one time call一次性调用的kafka消费者轮询方法的行为
【发布时间】：2019-04-02 05:35:19
【问题描述】：

假设我只调用了一次 poll() 一次超时，而不是 while(true) {...poll...}

【问题讨论】：

根据我的实验，投票行为有点不确定。 (1) 使用 while(true) {...poll...}，每次轮询的记录数对我来说似乎是随机的 (2) 我也没有发现超时和每次轮询的记录数之间的关系。但绝对不能保证一次性获得所有可用记录请如果有人可以解释
这篇文章可能有最好的解释stackoverflow.com/questions/51753883/…

【解决方案1】：

根据kafka-doc，默认max.poll.records是500

单次调用poll()返回的最大记录数。

因此，每次调用 poll() 时，您都可以从上次提交的 offset 到 500 max.poll.records=500

【讨论】：