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

chia7712 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 671cbedc1bd KAFKA-18219 Use INFO level instead of ERROR after 
successfully performing an unclean leader election (#18159)
671cbedc1bd is described below

commit 671cbedc1bd2050b859fe983374e8414c4a3497a
Author: Nick Guo <[email protected]>
AuthorDate: Fri Dec 13 03:57:14 2024 +0800

    KAFKA-18219 Use INFO level instead of ERROR after successfully performing 
an unclean leader election (#18159)
    
    Reviewers: Kuan-Po Tseng <[email protected]>, Chia-Ping Tsai 
<[email protected]>
---
 .../java/org/apache/kafka/controller/ReplicationControlManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 6bbbd03b48c..35eae955f14 100644
--- 
a/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
+++ 
b/metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
@@ -1767,7 +1767,7 @@ public class ReplicationControlManager {
                 ApiError result = electLeader(topic.name, 
topicIdPartition.partitionId(),
                         ElectionType.UNCLEAN, records);
                 if (result.error().equals(Errors.NONE)) {
-                    log.error("Triggering unclean leader election for offline 
partition {}-{}.",
+                    log.info("Triggering unclean leader election for offline 
partition {}-{}.",
                             topic.name, topicIdPartition.partitionId());
                 } else {
                     log.warn("Cannot trigger unclean leader election for 
offline partition {}-{}: {}",

Reply via email to