Как приостановить потребителя KafkaJS и повторить попытку через некоторое время
Я использую KafkaJS ( https://kafka.js.org/) для подключения к кластеру Kafka. Мои потребители несут ответственность за обработку задач, которые могут завершиться ошибкой в какой-то момент и успешно завершиться через некоторое время ожидания (например, 1 час). До этого срока любая попытка обработать какую-либо задачу приведет к другому сбою.
Я попытался использовать метод Pause & Resume, как описано на https://kafka.js.org/docs/consuming. Тем не менее, потребитель немедленно перезапускается и снова продолжает использовать сбойную задачу.
Как я могу приостановить получение сообщений, не зафиксировав неудачное, и немедленно перезапустить потребителя?