[kafka] branch trunk updated: MINOR: Print the cached broker epoch (#11005)

[davidarthur]

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

davidarthur 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 f6d6bcc  MINOR: Print the cached broker epoch (#11005)
f6d6bcc is described below

commit f6d6bcc153618893932bbe53340d823932ac4e70
Author: José Armando García Sancio <jsan...@users.noreply.github.com>
AuthorDate: Fri Jul 9 11:17:57 2021 -0700

    MINOR: Print the cached broker epoch (#11005)
    
    When the broker epochs do not match make sure to print both broker epochs.
---
 core/src/main/scala/kafka/controller/KafkaController.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala 
b/core/src/main/scala/kafka/controller/KafkaController.scala
index 5b463a6..81b193e 100644
--- a/core/src/main/scala/kafka/controller/KafkaController.scala
+++ b/core/src/main/scala/kafka/controller/KafkaController.scala
@@ -2302,7 +2302,7 @@ class KafkaController(val config: KafkaConfig,
     }
 
     if (!brokerEpochOpt.contains(brokerEpoch)) {
-      info(s"Ignoring AlterIsr due to stale broker epoch $brokerEpoch for 
broker $brokerId")
+      info(s"Ignoring AlterIsr due to stale broker epoch $brokerEpoch and 
local broker epoch $brokerEpochOpt for broker $brokerId")
       callback.apply(Right(Errors.STALE_BROKER_EPOCH))
       return
     }