From a8829b2c4c809cc903dc78aae26af800ac7e5b64 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Daniel=20F=C4=85derski?= <faderskd@users.noreply.github.com>
Date: Fri, 15 Mar 2024 15:45:48 +0100
Subject: [PATCH] Reduce number of logs from retransmission (#1775)

---
 .../consumers/supervisor/workload/WorkloadSupervisor.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/supervisor/workload/WorkloadSupervisor.java b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/supervisor/workload/WorkloadSupervisor.java
index be74d37319..1e85e5b351 100644
--- a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/supervisor/workload/WorkloadSupervisor.java
+++ b/hermes-consumers/src/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);
         }
     }