From c2b38503f2901ff3b1e92b99a8527fdc62acb77e Mon Sep 17 00:00:00 2001 From: "S.Y. Wang" Date: Thu, 13 Feb 2025 20:06:30 +0900 Subject: [PATCH] MINOR: Fix typo in ClusterControlManager (#18886) Reviewers: TengYao Chi , Ken Huang , Chia-Ping Tsai --- .../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()); }