本文介绍了max.poll.records如何影响消费者调查的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

max.poll.records最近在kafka消费者配置中已更改为500,但我想知道这如何影响消费者调查.它只是可以获取的最大记录数的上限,还是消费者等待直到获得500条记录.

max.poll.records has been recently changed to 500 in kafka consumer config, but I am wondering how does this affect the consumer poll. Is it just an upper bound of the maximum number of records that could be fetched or the consumer waits till it gets 500 records.

推荐答案

max.poll.records:是,来自新使用者,默认情况下此属性更改为500,这意味着使用者可以轮询至少1到每次轮询最多500条记录,这意味着当分区没有足够的数据时,消费者不会等待

max.poll.records : Yes from new consumer this property is changed to 500 by default which means consumer can poll minimum 1 to max 500 records for each poll, and which means consumer will not wait when partition did not have sufficient data

fetch.min.bytes::默认情况下为1个字节,如果您增加此配置,消费者将等待.

fetch.min.bytes : By default it is 1 byte, consumer will wait if you increase this configuration.

这篇关于max.poll.records如何影响消费者调查的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

10-14 20:40