From 5fd178b8dc9928983970d6081afd2d3b706adfc6 Mon Sep 17 00:00:00 2001 From: daniel-davidd <135515059+daniel-davidd@users.noreply.github.com> Date: Mon, 4 Sep 2023 14:41:59 +0300 Subject: [PATCH] default station logs severity (#1301) * changed from error to warn * check if its an already exist log --------- Co-authored-by: daniel-davidd --- server/memphis_handlers_producers.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/server/memphis_handlers_producers.go b/server/memphis_handlers_producers.go index 78114d433..751a983eb 100644 --- a/server/memphis_handlers_producers.go +++ b/server/memphis_handlers_producers.go @@ -82,7 +82,11 @@ func (s *Server) createProducerDirectCommon(c *client, pName, pType, pConnection var created bool station, created, err = CreateDefaultStation(user.TenantName, s, pStationName, user.ID, user.Username, "", 0) if err != nil { - serv.Errorf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error()) + if strings.Contains(err.Error(), "already exists") { + serv.Warnf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error()) + } else { + serv.Errorf("[tenant: %v][user: %v]createProducerDirectCommon at CreateDefaultStation: creating default station error - producer %v at station %v: %v", user.TenantName, user.Username, pName, pStationName.external, err.Error()) + } return false, false, err, models.Station{} } if created {