root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Fix typo in ClusterControlManager (#18886) 

Reviewers: TengYao Chi <kitingiao@gmail.com>, Ken Huang <s7133700@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
S.Y. Wang 2025-02-13 20:06:30 +09:00 committed by GitHub
parent 9494bebee6
commit c2b38503f2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
View File

@ -680,7 +680,7 @@ public class ClusterControlManager {
ControllerRegistration newRegistration = new ControllerRegistration.Builder(record).build(); ControllerRegistration newRegistration = new ControllerRegistration.Builder(record).build();
ControllerRegistration prevRegistration = ControllerRegistration prevRegistration =
controllerRegistrations.put(record.controllerId(), newRegistration); controllerRegistrations.put(record.controllerId(), newRegistration);
log.info("Replayed RegisterControllerRecord contaning {}.{}", newRegistration, log.info("Replayed RegisterControllerRecord containing {}.{}", newRegistration,
prevRegistration == null ? "" : prevRegistration == null ? "" :
" Previous incarnation was " + prevRegistration.incarnationId()); " Previous incarnation was " + prevRegistration.incarnationId());
} }