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