You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2025/02/13 11:06:37 UTC
(kafka) branch trunk updated: MINOR: Fix typo in ClusterControlManager (#18886)
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 c2b38503f29 MINOR: Fix typo in ClusterControlManager (#18886)
c2b38503f29 is described below
commit c2b38503f2901ff3b1e92b99a8527fdc62acb77e
Author: S.Y. Wang <jo...@gmail.com>
AuthorDate: Thu Feb 13 20:06:30 2025 +0900
MINOR: Fix typo in ClusterControlManager (#18886)
Reviewers: TengYao Chi <ki...@gmail.com>, Ken Huang <s7...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>
---
.../main/java/org/apache/kafka/controller/ClusterControlManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
index 087d47c570d..9659eb4945c 100644
--- a/metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
+++ b/metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
@@ -680,7 +680,7 @@ public class ClusterControlManager {
ControllerRegistration newRegistration = new ControllerRegistration.Builder(record).build();
ControllerRegistration prevRegistration =
controllerRegistrations.put(record.controllerId(), newRegistration);
- log.info("Replayed RegisterControllerRecord contaning {}.{}", newRegistration,
+ log.info("Replayed RegisterControllerRecord containing {}.{}", newRegistration,
prevRegistration == null ? "" :
" Previous incarnation was " + prevRegistration.incarnationId());
}