卡夫卡一次性消费者调查方法的行为分析

Question

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

1. 消费者会不会从最后一次提交的所有记录到最新的一次拍摄？
2. 超时参数重要吗？例如，如果timeout==0和数百万的记录，会发生什么？

Answer 1

根据卡夫卡-医生，默认情况下，max.poll.records是500

在对poll()的单个调用中返回的最大记录数。

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