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 {}-{}: {}",