哪个kafka属性决定了KafkaConsumer的轮询频率？

KafkaConsumer的轮询频率由属性max.poll.interval.ms决定。

max.poll.interval.ms属性定义了消费者在两次poll之间的最大时间间隔。如果消费者在这个时间间隔内没有发送心跳给Kafka服务器，那么Kafka服务器将认为该消费者出现了故障，并将其从消费组中移除。

以下是一个使用Java代码示例，演示了如何设置max.poll.interval.ms属性：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.Properties;

public class KafkaConsumerExample {

    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-consumer-group");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
        props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "5000"); // 设置max.poll.interval.ms属性为5000ms

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
        consumer.subscribe(Arrays.asList("my-topic"));

        while (true) {
            consumer.poll(Duration.ofMillis(100)); // 设置每次轮询的时间间隔
            // 处理接收到的消息
            // ...
        }
    }
}

在上述代码中，通过props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "5000")语句将max.poll.interval.ms属性设置为5000毫秒（即5秒）。这意味着消费者必须在5秒内发送心跳给Kafka服务器，否则将被认为是故障。