В приложении потоков kafka, если метод process () в вашем процессоре генерирует необработанное исключение, потоковая задача будет уничтожена.Однако если у вас есть метод punctuate () (использующий context.schedule ()) и он генерирует необработанное исключение, задача не будет убита.Почему это?Как правильно убить задачу, если вы хотите, чтобы необработанные исключения в punctuate () останавливали задачу?