From f03b8884387412a826915036a90991a6d5ac2948 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Denis=20Nu=C8=9Biu?= Date: Tue, 7 Mar 2023 09:32:13 +0200 Subject: [PATCH] Update main.go --- main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/main.go b/main.go index 4be8a6a..48ad80b 100644 --- a/main.go +++ b/main.go @@ -73,7 +73,7 @@ func main() { go speedyPusher.RunForever() isRunning := true var waitGroup sync.WaitGroup - for i := 0; i < config.KafkaPollingGoroutines; i++ { + for i := 0; i < 1; i++ { waitGroup.Add(1) go func() { defer waitGroup.Done()