(kafka) branch 4.1 updated: MINOR: Fix log messages for epoch comparison in ReplicationControlManager (#21729)

[jlprat]

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

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


The following commit(s) were added to refs/heads/4.1 by this push:
     new bc22d7b32b8 MINOR: Fix log messages for epoch comparison in 
ReplicationControlManager (#21729)
bc22d7b32b8 is described below

commit bc22d7b32b884e86645db3eaf462369072f65aa9
Author: Giuseppe Lillo <giuseppe.li...@aiven.io>
AuthorDate: Fri Mar 13 20:12:10 2026 +0100

    MINOR: Fix log messages for epoch comparison in ReplicationControlManager 
(#21729)
    
    Log messages in
    
    
`org.apache.kafka.controller.ReplicationControlManager#validateAlterPartitionData`
    are misleading and are not coherent with the other log messages (where
    "current" indicate the controller state coming from
    PartitionRegistration).
    
    Reviewers: Josep Prat <josep.p...@aiven.io>
---
 .../java/org/apache/kafka/controller/ReplicationControlManager.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
 
b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
index 22c8de053a0..e6e7e196401 100644
--- 
a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+++ 
b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
@@ -1247,13 +1247,13 @@ public class ReplicationControlManager {
         // this case to give the leader an opportunity to find the new 
controller.
         if (partitionData.leaderEpoch() > partition.leaderEpoch) {
             log.debug("Rejecting AlterPartition request from node {} for {}-{} 
because " +
-                    "the current leader epoch is {}, which is greater than the 
local value {}.",
+                    "the current leader epoch is {}, which is lower than the 
request value {}. {}",
                 brokerId, topic.name, partitionId, partition.leaderEpoch, 
partitionData.leaderEpoch());
             return NOT_CONTROLLER;
         }
         if (partitionData.partitionEpoch() > partition.partitionEpoch) {
             log.debug("Rejecting AlterPartition request from node {} for {}-{} 
because " +
-                    "the current partition epoch is {}, which is greater than 
the local value {}.",
+                    "the current partition epoch is {}, which is lower than 
the request value {}. {}",
                 brokerId, topic.name, partitionId, partition.partitionEpoch, 
partitionData.partitionEpoch());
             return NOT_CONTROLLER;
         }