Reduce number of logs from retransmission (#1775)

allegro · Mar 15, 2024 · a8829b2 · a8829b2
1 parent acf7b38
commit a8829b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/java/pl/allegro/tech/hermes/consumers/supervisor/workload/WorkloadSupervisor.java b/...rc/main/java/pl/allegro/tech/hermes/consumers/supervisor/workload/WorkloadSupervisor.java
@@ -170,8 +170,8 @@ public boolean isLeader() {
 
     @Override
     public void onRetransmissionStarts(SubscriptionName subscription) throws Exception {
-        logger.info("Triggering retransmission for subscription {}", subscription);
         if (assignmentCache.isAssignedTo(subscription)) {
+            logger.info("Triggering retransmission for subscription {}", subscription);
             supervisor.retransmit(subscription);
         }
     }