From 60790d2b38d1bbc8fe39c5984e69d06fabbdd71b Mon Sep 17 00:00:00 2001
From: Andrii Landiak <andriylandiak@gmail.com>
Date: Fri, 29 Nov 2024 15:34:51 +0200
Subject: [PATCH] Improve log strategy

---
 .../server/service/ttl/KafkaEdgeTopicsCleanUpService.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/ttl/KafkaEdgeTopicsCleanUpService.java b/application/src/main/java/org/thingsboard/server/service/ttl/KafkaEdgeTopicsCleanUpService.java
index 6a3a0271da..d801dc2bbe 100644
--- a/application/src/main/java/org/thingsboard/server/service/ttl/KafkaEdgeTopicsCleanUpService.java
+++ b/application/src/main/java/org/thingsboard/server/service/ttl/KafkaEdgeTopicsCleanUpService.java
@@ -88,14 +88,13 @@ public class KafkaEdgeTopicsCleanUpService extends AbstractCleanUpService {
         TbKafkaAdmin kafkaAdmin = new TbKafkaAdmin(kafkaSettings, kafkaTopicConfigs.getEdgeEventConfigs());
         Set<String> topics = kafkaAdmin.getAllTopics();
         if (topics == null || topics.isEmpty()) {
-            log.warn("No topics found in Kafka. Skipping cleanup.");
             return;
         }
 
         String edgeTopicPrefix = topicService.buildTopicName(EDGE_EVENT_TOPIC_NAME);
         List<String> matchingTopics = topics.stream().filter(topic -> topic.startsWith(edgeTopicPrefix)).toList();
         if (matchingTopics.isEmpty()) {
-            log.info("No matching topics found with prefix [{}]. Skipping cleanup.", edgeTopicPrefix);
+            log.debug("No matching topics found with prefix [{}]. Skipping cleanup.", edgeTopicPrefix);
             return;
         }