From d46441e51931ebe7822dbb8aeff0efd70b391acd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?U=C4=9Furcan=20Erdo=C4=9Fan?= Date: Fri, 5 Jul 2024 17:03:49 +0300 Subject: [PATCH] feat: fix duration logic for the flag --- internal/cron.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/cron.go b/internal/cron.go index d81a952..dd3a10d 100644 --- a/internal/cron.go +++ b/internal/cron.go @@ -87,5 +87,7 @@ func (s *cronsumer) startConsume(cfg kafka.ConsumerConfig) { go s.consumer.Listen(ctx, cfg.BackOffStrategy.String(), &cancelFuncWrapper) - time.AfterFunc(cfg.Duration, cancelFuncWrapper) + if !cfg.DisableExceptionCron { + time.AfterFunc(cfg.Duration, cancelFuncWrapper) + } }