feat(broker): add more logs when broker register to controller

1. add more logs when broker register to controller
This commit is contained in:
TheR1sing3un
2023-03-12 00:29:26 +08:00
committed by rongtong
parent 935e6d573d
commit ce418c907c
3 changed files with 23 additions and 0 deletions
@@ -420,6 +420,7 @@ public class ReplicasManager {
if (this.registerState == RegisterState.INITIAL) {
Long nextBrokerId = getNextBrokerId();
if (nextBrokerId == null || !createTempMetadataFile(nextBrokerId)) {
LOGGER.error("Failed to create temp metadata file, nextBrokerId: {}", nextBrokerId);
return false;
}
this.registerState = RegisterState.CREATE_TEMP_METADATA_FILE_DONE;
@@ -435,6 +436,7 @@ public class ReplicasManager {
return false;
}
if (!createMetadataFileAndDeleteTemp()) {
LOGGER.error("Failed to create metadata file and delete temp metadata file, temp metadata: {}", this.brokerMetadata);
return false;
}
this.registerState = RegisterState.CREATE_METADATA_FILE_DONE;
@@ -94,4 +94,14 @@ public class BrokerMetadata extends MetadataFile {
public int hashCode() {
return Objects.hash(clusterName, brokerName, brokerId);
}
@Override
public String toString() {
return "BrokerMetadata{" +
"clusterName='" + clusterName + '\'' +
", brokerName='" + brokerName + '\'' +
", brokerId=" + brokerId +
", filePath='" + filePath + '\'' +
'}';
}
}
@@ -81,4 +81,15 @@ public class TempBrokerMetadata extends BrokerMetadata {
public String getRegisterCheckCode() {
return registerCheckCode;
}
@Override
public String toString() {
return "TempBrokerMetadata{" +
"registerCheckCode='" + registerCheckCode + '\'' +
", clusterName='" + clusterName + '\'' +
", brokerName='" + brokerName + '\'' +
", brokerId=" + brokerId +
", filePath='" + filePath + '\'' +
'}';
}
}