(pulsar) branch branch-4.1 updated: [fix][broker] Lower log level of DrainingHashesTracker not-found entry to DEBUG (#25558)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.1 by this push:
     new c1548fe4ae9 [fix][broker] Lower log level of DrainingHashesTracker 
not-found entry to DEBUG (#25558)
c1548fe4ae9 is described below

commit c1548fe4ae9d7fb64b7c07d97f809e19b92e7193
Author: Vishal Kumar Singh <vishal.kr.singh2...@gmail.com>
AuthorDate: Wed Apr 22 04:01:05 2026 +0530

    [fix][broker] Lower log level of DrainingHashesTracker not-found entry to 
DEBUG (#25558)
    
    (cherry picked from commit 423a74698e1b44652425f030788ac54484052f85)
---
 .../java/org/apache/pulsar/broker/service/DrainingHashesTracker.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
index 51c45817368..8570e2f4d36 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
@@ -185,8 +185,8 @@ public class DrainingHashesTracker {
                     int hash = hashIterator.nextInt();
                     DrainingHashEntry entry = getEntry(hash);
                     if (entry == null) {
-                        log.warn("[{}] Draining hash {} not found in the 
tracker for consumer {}", dispatcherName, hash,
-                                consumer);
+                        log.debug("[{}] Draining hash {} not found in the 
tracker for consumer {}", dispatcherName,
+                                hash, consumer);
                         continue;
                     }
                     int unackedMessages = entry.getRefCount();