我有一个springboot应用程序，它用springkafka听一个kafka主题。在消息被使用之后，使用消息中的信息执行几个web/rest服务调用，以收集一些其他数据，这个过程需要一些预期的时间。因此，我使用了一个大小为20的线程池来创建一个并行消息处理。
这个系统通常运行良好，但很少有大量的消息（大约200k）在短时间（1秒）内放入/产生到Kafka主题。在这种情况下，消费者会立即消费消息，但消息处理机制不够快。因此，在等待线程时，所有消耗的消息都会留在内存中，而应用程序会从内存错误中退出。
将线程池大小增加到一定程度可以是一种改进，但这并不是解决此问题的永久解决方案。我想在一段时间内消耗的消息数量和处理的消息数量之间建立一个平衡。这可以限制从Kafka主题中消耗的消息的数量，或者在有可能立即处理消息时消耗消息。
有没有Kafka消费者配置来限制一段时间内的消息数量？当消息消耗的延迟不是问题时，如何优化消耗和处理机制？
ps：两次后续轮询之间的时间间隔似乎没有配置（每次轮询之间的延迟时间是多少），如果有，可能有一个配置的解决方案。
这是我的消费代码：

@Autowired
MessageProcessUtil messageProcessUtil;

private ExecutorService executor = Executors.newFixedThreadPool(20);

@KafkaListener(topics = "${kafka.consumer.topicName}")
public void consume(String message){
    logger.info(String.format("$$ -> Consumed Message -> %s",message));
    messageProcessUtil.processMessage(message, executor);
}

使用者配置：

kafka.consumer.enable.auto.commit=true
kafka.consumer.auto.commit.interval.ms=1000
kafka.consumer.request.timeout.ms=40000
kafka.consumer.session.timeout.ms=30000
kafka.consumer.max.poll.records=1
kafka.consumer.fetch.max.wait.ms=500
kafka.consumer.auto.offset.reset=earliest

事先谢谢你的帮助。