RHINENG-10027: more verbose startup logging

RedHatInsights · May 14, 2024 · ddf9e11 · ddf9e11
1 parent 65a749a
commit ddf9e11
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/listener/listener.go b/listener/listener.go
@@ -89,14 +89,15 @@ func runReaders(wg *sync.WaitGroup, readerBuilder mqueue.CreateReader) {
 	// algorithm assigns each consumer a single partition
 	for i := 0; i < eventsConsumers; i++ {
 		mqueue.SpawnReader(wg, eventsTopic, readerBuilder, mqueue.MakeRetryingHandler(EventsMessageHandler))
-		utils.LogTrace("spawned eventsTopic reader", i)
+		utils.LogDebug("spawned eventsTopic reader", i)
 	}
 	if enableTemplates {
 		for i := 0; i < templatesConsumers; i++ {
 			mqueue.SpawnReader(wg, templatesTopic, readerBuilder, mqueue.MakeRetryingHandler(TemplatesMessageHandler))
-			utils.LogTrace("spawned templatesTopic reader", i)
+			utils.LogDebug("spawned templatesTopic reader", i)
 		}
 	}
+	utils.LogInfo("connected to kafka topics")
 }
 
 func RunListener() {