chia7712 commented on code in PR #22319:
URL: https://github.com/apache/kafka/pull/22319#discussion_r4490566904
##########
core/src/main/scala/kafka/server/KafkaRaftServer.scala:
##########
@@ -55,6 +55,8 @@ class KafkaRaftServer(
private val (metaPropsEnsemble, bootstrapMetadata) =
KafkaRaftServer.initializeLogDirs(config, this.logger.underlying,
this.logIdent)
+ info(s"Loaded cluster id ${metaPropsEnsemble.clusterId().get()} from
meta.properties")
Review Comment:
It seems this log is duplicated :) The cluster ID is already logged during
startup, right after the raft client starts.
```java
log.info("Creating new QuorumController with clusterId {}",
clusterId);
```
```java
logger.info("Incarnation {} of broker {} in cluster {} is now
STARTING.", incarnationId, nodeId, clusterId);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
