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());
     }