(kafka) branch trunk updated: KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG (#22055)

[lianetm]

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

lianetm pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new a39e714c6f6 KAFKA-20449: Downgrade "not updating high watermark" log 
from WARN to DEBUG (#22055)
a39e714c6f6 is described below

commit a39e714c6f65c04b4b6f2a9188ab066ac2828be8
Author: Tamas Kornai <tamas.kor...@wise.com>
AuthorDate: Tue Apr 14 20:04:45 2026 +0200

    KAFKA-20449: Downgrade "not updating high watermark" log from WARN to DEBUG 
(#22055)
    
    ## Summary
    
    - Downgrade the "Not updating high watermark" and "Not updating last
    stable offset" log messages in
    `OffsetFetcherUtils.updateSubscriptionState()` from `WARN` to `DEBUG`.
    - These messages were added in KAFKA-20131 (commit abcbef6a4c) for the
    case where a `LIST_OFFSETS` response arrives after a partition has
    already been revoked during a rebalance.
    - This is a benign race condition that requires no operator action, but
    the `WARN` level causes problems for deployments that use warning rates
    as a health signal — e.g., canary releases get rolled back due to the
    high volume of warnings during rebalances.
    
    ## Test plan
    
    - [x] Verify existing `OffsetFetcherUtils` tests pass
    - [x] Confirm no tests assert on the log level of these messages
    
    🤖 Generated with [Claude Code](https://claude.com/claude-code)
    
    Reviewers: Lianet Magrans <98415067+lian...@users.noreply.github.com>
    
    Co-authored-by: Claude Opus 4.6 <nore...@anthropic.com>
---
 .../apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java
index f6f324be070..d2277882277 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java
@@ -279,9 +279,9 @@ class OffsetFetcherUtils {
                 }
             } else {
                 if (isolationLevel == IsolationLevel.READ_COMMITTED) {
-                    log.warn("Not updating last stable offset for partition {} 
as it is no longer assigned", partition);
+                    log.debug("Not updating last stable offset for partition 
{} as it is no longer assigned", partition);
                 } else {
-                    log.warn("Not updating high watermark for partition {} as 
it is no longer assigned", partition);
+                    log.debug("Not updating high watermark for partition {} as 
it is no longer assigned", partition);
                 }
             }
         }