Kafka设置每分钟最大消费记录数

在Kafka的消费者配置文件中，有一个参数可以控制每分钟消费的最大记录数，即max.poll.records。默认值是500条记录，但可以根据实际需要进行更改。以下是一个示例配置文件：

bootstrap.servers=my-kafka-broker:9092
group.id=my-group
enable.auto.commit=true
auto.commit.interval.ms=1000
max.poll.records=1000

这里将max.poll.records设置为1000条记录，表示每分钟最大消费记录数为1000条。可以根据实际情况酌情修改该值。

在使用Kafka消费者API时，可以如下设置该参数：

Properties props = new Properties();
props.put("bootstrap.servers", "my-kafka-broker:9092");
props.put("group.id", "my-group");
props.put("enable.auto.commit", "true");
props.put("auto.commit.interval.ms", "1000");
props.put("max.poll.records", "1000");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

同样，将max.poll.records设置为1000即可。

需要注意的是，增加每分钟最大消费记录数可能会占用更多资源，因此需要根据实际情况进行平衡。