Change log level for commit response from info to debug

ydb-platform · Dec 14, 2023 · 7bfc71c · 7bfc71c
1 parent 287ff32
commit 7bfc71c
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/topic/src/main/java/tech/ydb/topic/read/impl/PartitionSessionImpl.java b/topic/src/main/java/tech/ydb/topic/read/impl/PartitionSessionImpl.java
@@ -245,10 +245,12 @@ public void handleCommitResponse(long committedOffset) {
             return;
         }
         Map<Long, CompletableFuture<Void>> futuresToComplete = commitFutures.headMap(committedOffset, true);
-        logger.info("[{}] Commit response received for partition session {} (partition {}). Committed offset: {}" +
-                        ". Previous committed offset: {} (diff is {} message(s)). Completing {} commit futures",
-                path, id, partitionId, committedOffset, lastCommittedOffset, committedOffset - lastCommittedOffset,
-                futuresToComplete.size());
+        if (logger.isDebugEnabled()) {
+            logger.debug("[{}] Commit response received for partition session {} (partition {}). Committed offset: {}" +
+                            ". Previous committed offset: {} (diff is {} message(s)). Completing {} commit futures",
+                    path, id, partitionId, committedOffset, lastCommittedOffset, committedOffset - lastCommittedOffset,
+                    futuresToComplete.size());
+        }
         lastCommittedOffset = committedOffset;
         futuresToComplete.values().forEach(future -> future.complete(null));
         futuresToComplete.clear();