卡夫卡消费者配置

问题描述 投票:0回答:1

如何配置使用者,以便在单次轮询中一次轮询50条记录。我已经创建了max_poll_records设置为50的消费者。但我的消费者在时间消耗单个记录。配置消费者以便它在单个轮询中获取50个记录。

apache-kafka kafka-consumer-api
1个回答
0
投票

设置max.poll.records时,使用者最多返回配置的最大记录数。比如说,如果您的主题包含1000个未读记录且max.poll.records设置为50,那么消费者将在每个poll调用中仅返回50条记录。但是,如果您的主题仅包含5个未读记录,则会立即返回5条记录。

如果要批量处理记录,则可能必须在列表中累积记录,然后在大小到达时处理它。注意:您必须禁用自动提交,并且应在处理完所有50条记录后手动提交。

© www.soinside.com 2019 - 2024. All rights reserved.