直接配置max.poll.interval.ms参数即可，它是控制消费者两次poll()调用最大允许时间的核心参数，需在创建KafkaConsumer实例时通过Properties设置，单位毫秒；Spring Boot中可在application.yml配置，原生示例为props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 60000)；必须同步调整session.timeout.ms（≤该值，推荐1/3）和heartbeat.interval.ms（＜session.timeout.ms，通常1/3）；Kafka不支持按主题单独配置，需为不同主题启动独立消费者实例并分别配置；可通过kafka-consumer-groups.sh命令及日志中“rebalance”等关键词验证是否生效。
直接配置 max.poll.interval.ms 参数即可，这是控制消费者两次 poll() 调用最大允许时间的核心参数。
关键配置方式
该参数需在创建 KafkaConsumer 实例时通过 Properties 设置，单位为毫秒：
- Spring Boot 中可在
application.yml或@Configuration类里配置：spring.kafka.consumer.properties.max.poll.interval.ms=300000（默认 5 分钟） - 原生 KafkaConsumer 示例：
props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 60000); // 设为 60 秒 - 注意：必须配合合理的
max.poll.records和实际处理耗时使用，否则容易触发重平衡
必须同步调整的关联参数
单独调大 max.poll.interval.ms 不够，还需协调以下两个心跳相关参数：
-
session.timeout.ms：消费者会话超时时间，必须 ≤max.poll.interval.ms（推荐设为后者的 1/3 左右） -
heartbeat.interval.ms：心跳发送间隔，必须<session.timeout.ms（通常设为 session 的 1/3） - 例如：若设
max.poll.interval.ms=60000，建议session.timeout.ms=30000，heartbeat.interval.ms=10000
按主题差异化配置的正确做法
Kafka 不支持对单个主题单独设置 max.poll.interval.ms，因为它是消费者实例级参数。如需为不同主题设定不同处理时限：
- 为每个主题（或处理逻辑差异大的主题）启动独立的消费者实例
- 每个实例单独配置对应的
max.poll.interval.ms、session.timeout.ms等参数 - 订阅时仅指定目标主题，避免混用
验证是否生效
启动消费者后，可通过 Kafka 命令行工具观察组状态：
kafka-consumer-groups.sh --bootstrap-server xxx --group your-group-id --describe- 检查输出中是否有频繁的
REBALANCING状态；若不再频繁触发，说明配置已起作用 - 结合应用日志，搜索 “rebalance”、“heartbeat failed”、“group is rebalancing” 等关键词确认问题是否缓解
