(kafka) branch trunk 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 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 c49bf98e0fd MINOR: Fix log messages for epoch comparison in 
ReplicationControlManager (#21729)
c49bf98e0fd is described below

commit c49bf98e0fdde6f852e94f163dbeff174da68297
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 7e991169e9a..198e8b2f4ed 100644
--- 
a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+++ 
b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
@@ -1267,14 +1267,14 @@ 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(),
                 logPartitionChangeInfo(partition, 
partitionData.newIsrWithEpochs()));
             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(),
                 logPartitionChangeInfo(partition, 
partitionData.newIsrWithEpochs()));
             return NOT_CONTROLLER;