fix: endless kafka initialisation loop

butschi84 · Dec 3, 2023 · dbc041f · dbc041f
1 parent 5a57bae
commit dbc041f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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