我观察到，Kafka消费滞后在运行数小时/天之后突然开始增加。
在查看日志时，我看到了很多异常：
org.apache.kafka.clients.consumer.retriablecommitfailedexception:偏移提交失败，出现可检索异常。您应该重试提交最新消耗的偏移量。
我的consumerthread课程：

public class ConsumerThread implements Runnable {
  private final KafkaConsumer<String, Map<String, Object>> consumer;
  public ConsumerThread(
    this.consumer = new KafkaConsumer<>(getConsumerConfig(kafkaConfiguration));
  }

  @Override
  public void run() {
    try {
      consumer.subscribe(topicList);

      while (true) {
        ConsumerRecords<String, Map<String, Object>> records =
            consumer.poll(Duration.ofMillis(kafkaConfiguration.getPollIntervalMs()));

        long startPerPoll = System.nanoTime();
        for (final ConsumerRecord<String, Map<String, Object>> record : records) {
            // message processing logic here
        }

        consumer.commitAsync((offsets, exception) -> {
            if (exception != null) {
              //log.error(exception.getMessage());
              log.info("exception while committing offset, consumerThread: {}, exception: {}", Thread.currentThread().getName(), exception);
              exception.printStackTrace();
            }
        });

      }
    } catch (Exception e) {
      // ignore for shutdown
      log.info("exception in run for consumerThread: {}", e);
    } finally {
      try {
        if (Objects.nonNull(consumer)) {
          consumer.commitSync();
        }
      } finally {
        if (Objects.nonNull(consumer)) {
          consumer.close();
        }
      }
    }
}

我的Kafka配置：

groupId: cep-cg
autoCommitEnabled: false
sessionTimeoutMs: 30000
heartBeatIntervalMs: 10000
autoOffsetReset: latest
maxPollRecord: 250
maxPollIntervalMs: 180000
requestTimeoutMs: 240000
pollIntervalMs: 3000

我检查了stackoverflow上的其他答案，并做了一些调整，但似乎都不起作用。
我想知道的是：
有什么线索可以解释为什么延迟会突然增加？
是否有可能有很多commitasync请求在代理上挂起，并且可能有一段时间（由代理上的某个配置定义）commitasync请求开始失败？
比方说，一个消费者阅读了更多 max.poll.interval.ms 是时候处理消息了。在这种情况下，它将被踢出组并触发重新平衡。现在所有的 commitAsync 代理上挂起的请求失败 CommitFailedException 因为分区现在属于组中的其他使用者。在上面的代码中，使用者将跳出无限循环，并将永远关闭。这样对吗？还是我该抓住 CommitFailedException 再次恢复循环以保持消费者的活力？