SKYEDEN-3234 | Add more logging

allegro · Nov 13, 2024 · a2d47ca · a2d47ca
1 parent ebc1541
commit a2d47ca
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...gro/tech/hermes/management/infrastructure/detection/InactiveTopicsDetectionScheduler.java b/...gro/tech/hermes/management/infrastructure/detection/InactiveTopicsDetectionScheduler.java
@@ -16,7 +16,7 @@
 import pl.allegro.tech.hermes.management.infrastructure.zookeeper.ZookeeperClient;
 import pl.allegro.tech.hermes.management.infrastructure.zookeeper.ZookeeperClientManager;
 
-@ConditionalOnProperty(value = "detection.inactive-topics.enabled", havingValue = "true")
+@ConditionalOnProperty(prefix = "detection.inactive-topics", value = "enabled", havingValue = "true")
 @Component
 @EnableConfigurationProperties(InactiveTopicsDetectionProperties.class)
 public class InactiveTopicsDetectionScheduler {
@@ -42,6 +42,8 @@ public InactiveTopicsDetectionScheduler(
     this.leaderLatch = leaderCuratorFramework.map(it -> new LeaderLatch(it, leaderPath));
     if (leaderLatch.isEmpty()) {
       logLeaderZookeeperClientNotFound(leaderElectionDc);
+    } else {
+      logger.info("Found leader Zookeeper Client, leader latch created");
     }
     this.job = job;
   }
@@ -50,6 +52,7 @@ public InactiveTopicsDetectionScheduler(
   public void startListeningForLeadership() {
     leaderLatch.ifPresent(
         it -> {
+          logger.info("Starting listening for leadership");
           try {
             it.start();
           } catch (Exception e) {
@@ -64,6 +67,8 @@ public void run() {
       if (leaderLatch.get().hasLeadership()) {
         logger.info("Inactive topics detection started");
         job.detectAndNotify();
+      } else {
+        logger.info("Inactive topics detection not started - not a leader");
       }
     } else {
       logLeaderZookeeperClientNotFound(leaderElectionDc);