我尝试使用这里提到的轮询之间的空闲来减慢消耗速率，我还使用max.poll.interval.ms将轮询之间的空闲加倍，但它总是触发分区重新平衡，[编辑]我有5台主机，我将并发级别设置为1 [编辑2]我将轮询之间的空闲时间设置为5 min和max.poll.interval。毫秒到10分钟我还注意到这个日志“即将关闭空闲连接从105由于被闲置为540012米利斯”.我减少了轮询之间的空闲到10秒和问题消失，任何想法为什么？

private ConsumerFactory<String, GenericRecord> dlqConsumerFactory() {
        Map<String, Object> configurationProperties = commonConfigs();

        DlqConfiguration dlqConfiguration = kafkaProperties.getConsumer().getDlq();

        final Integer idleBetweenPollInterval = dlqConfiguration.getIdleBetweenPollInterval()
                .orElse(DLQ_POLL_INTERVAL);

        final Integer maxPollInterval = idleBetweenPollInterval * 2; // two times the idleBetweenPoll, to prevent re-balancing
        logger.info("Setting max poll interval to {} for DLQ", maxPollInterval);

        overrideIfRequired(DQL_CONSUMER_CONFIGURATION, configurationProperties, ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, maxPollInterval);

        dlqConfiguration.getMaxPollRecords().ifPresent(maxPollRecords ->
                overrideIfRequired(DQL_CONSUMER_CONFIGURATION, configurationProperties, ConsumerConfig.MAX_POLL_RECORDS_CONFIG, maxPollRecords)
        );

        return new DefaultKafkaConsumerFactory<>(configurationProperties);
    }