From dbc041fd6a427a6ca84743af53ce9eb66b8df5d4 Mon Sep 17 00:00:00 2001 From: roman huesler Date: Sun, 3 Dec 2023 10:31:58 +0100 Subject: [PATCH] fix: endless kafka initialisation loop --- f2soperator/operation/kafka/main.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/f2soperator/operation/kafka/main.go b/f2soperator/operation/kafka/main.go index cdcf55b..956ba73 100644 --- a/f2soperator/operation/kafka/main.go +++ b/f2soperator/operation/kafka/main.go @@ -4,6 +4,7 @@ import ( "butschi84/f2s/hub" "butschi84/f2s/services/logger" "fmt" + "time" ) var logging logger.F2SLogger @@ -18,9 +19,8 @@ func Initialize(hub *hub.F2SHub) { f2shub = hub // check if kafka integration is enabled in config - if !hub.F2SConfiguration.Config.F2S.Kafka.Enabled { - logging.Info("kafka integration is disabled via config") - return + for !hub.F2SConfiguration.Config.F2S.Kafka.Enabled { + time.Sleep(10 * time.Second) } // get all configured kafka listeners