我正在使用 KafkaJS ( https://kafka.js.org ) 连接到 Kafka 集群。我的消费者负责处理可能在某个时间失败并在等待一段时间（例如，1 小时）后成功的任务。在此持续时间之前，任何处理任何任务的尝试都将导致另一个失败。
我尝试使用https://kafka.js.org/docs/sumption#a-name-pause-resume-a-pause-resume中所述的暂停和恢复方法。但是，消费者立即重新启动并继续再次消费失败的任务。
如何在不提交失败消息并立即重新启动消费者的情况下暂停消费消息？