From ddf9e116fe859b1ede18646e6ec90e4602d77b77 Mon Sep 17 00:00:00 2001 From: Michael Mraka Date: Mon, 13 May 2024 10:36:22 +0200 Subject: [PATCH] RHINENG-10027: more verbose startup logging --- listener/listener.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/listener/listener.go b/listener/listener.go index 8fcff19fa..f208db8fb 100644 --- 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() {