Kafka使用者具有一个配置max.poll.records,该配置可控制在对poll()的单次调用中返回的最大记录数,其默认值为500。我将其设置为非常高的数字,以便可以在一次轮询中获取所有消息。但是,民意测验在一个呼叫中仅返回数千条消息(大约6000条),即使该主题还有更多。如何进一步增加单个使用者读取的消息数量?
max.poll.records
apache-kafka
apache-kafka ×1