Kafka消费者配置

Question

如何配置消费者，使其在单次轮询中一次轮询50条记录。我已经创建了消费者，并将max_poll_records设置为50。但是我的消费者正在使用time.how中的单个记录来配置消费者，以便在一次轮询中获取50条记录。

Answer 1

当您设置max.poll.records时，使用者最多返回配置的最大记录数。比方说，如果您的主题包含1000条未读记录，并且max.poll.records设置为50，那么消费者在每次poll调用中将只返回50条记录。但是，如果您的主题只包含5条未读记录，它将立即返回这5条记录。

如果您想批量处理记录，那么您可能需要将记录累积到一个列表中，然后在大小达到一定值时进行处理。注意:您必须禁用自动提交，并在处理完所有50条记录后手动提交。