假设我打电话给你 poll() 只有一次超时，而不是 while(true) {...poll...} 消费者是否能一次性获得从上次提交到最新可用的所有记录？超时参数重要吗？e、 g.如果 timeout==0 有数百万条记录，会发生什么？
poll()
while(true) {...poll...}
timeout==0
gcmastyq1#
根据Kafka文件，默认情况下 max.poll.records 是 500 在对的单个调用中返回的最大记录数 poll() .所以，每次你打电话 poll() 你可以去500 max.poll.records=500 从上次提交 offset
max.poll.records
500
max.poll.records=500
offset
1条答案
按热度按时间gcmastyq1#
根据Kafka文件，默认情况下
max.poll.records是500在对的单个调用中返回的最大记录数poll().所以，每次你打电话
poll()你可以去500
max.poll.records=500从上次提交offset