8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

bugfix, fix underReplicatedPartitionCount

Browse Source
This commit is contained in:
zengqiao
2020-06-05 15:23:56 +08:00
parent f29b356b74
commit 64d64fe6fe
2 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
web/src/main/java/com/xiaojukeji/kafka/manager/web/converters/BrokerModelConverter.java
View File

@@ -78,6 +78,7 @@ public class BrokerModelConverter {
Double bytesInPerSec = brokerOverallDTO.getBytesInPerSec() / 1024.0 / 1024.0; Double bytesInPerSec = brokerOverallDTO.getBytesInPerSec() / 1024.0 / 1024.0;
brokerOverviewVO.setBytesInPerSec(Math.round(bytesInPerSec * 100) / 100.0); brokerOverviewVO.setBytesInPerSec(Math.round(bytesInPerSec * 100) / 100.0);
} }
brokerOverviewVO.setUnderReplicatedPartitionCount(brokerOverallDTO.getUnderReplicatedPartitions());
brokerOverviewVO.setLeaderCount(brokerOverallDTO.getLeaderCount()); brokerOverviewVO.setLeaderCount(brokerOverallDTO.getLeaderCount());
if (brokerOverallDTO.getPartitionCount() != null && brokerOverallDTO.getUnderReplicatedPartitions() != null) { if (brokerOverallDTO.getPartitionCount() != null && brokerOverallDTO.getUnderReplicatedPartitions() != null) {
brokerOverviewVO.setNotUnderReplicatedPartitionCount(brokerOverallDTO.getPartitionCount() - brokerOverallDTO.getUnderReplicatedPartitions()); brokerOverviewVO.setNotUnderReplicatedPartitionCount(brokerOverallDTO.getPartitionCount() - brokerOverallDTO.getUnderReplicatedPartitions());

15
web/src/main/java/com/xiaojukeji/kafka/manager/web/vo/broker/BrokerOverallVO.java
View File

@@ -30,9 +30,13 @@ public class BrokerOverallVO {
@ApiModelProperty(value = "分区数") @ApiModelProperty(value = "分区数")
private Integer partitionCount; private Integer partitionCount;
@ApiModelProperty(value = "未同步分区数") @Deprecated
@ApiModelProperty(value = "同步分区数")
private Integer notUnderReplicatedPartitionCount; private Integer notUnderReplicatedPartitionCount;
@ApiModelProperty(value = "未同步分区数")
private Integer underReplicatedPartitionCount;
@ApiModelProperty(value = "leader数") @ApiModelProperty(value = "leader数")
private Integer leaderCount; private Integer leaderCount;
@@ -103,6 +107,14 @@ public class BrokerOverallVO {
this.notUnderReplicatedPartitionCount = notUnderReplicatedPartitionCount; this.notUnderReplicatedPartitionCount = notUnderReplicatedPartitionCount;
} }
public Integer getUnderReplicatedPartitionCount() {
return underReplicatedPartitionCount;
}
public void setUnderReplicatedPartitionCount(Integer underReplicatedPartitionCount) {
this.underReplicatedPartitionCount = underReplicatedPartitionCount;
}
public Integer getLeaderCount() { public Integer getLeaderCount() {
return leaderCount; return leaderCount;
} }
@@ -130,6 +142,7 @@ public class BrokerOverallVO {
", bytesInPerSec=" + bytesInPerSec + ", bytesInPerSec=" + bytesInPerSec +
", partitionCount=" + partitionCount + ", partitionCount=" + partitionCount +
", notUnderReplicatedPartitionCount=" + notUnderReplicatedPartitionCount + ", notUnderReplicatedPartitionCount=" + notUnderReplicatedPartitionCount +
", underReplicatedPartitionCount=" + underReplicatedPartitionCount +
", leaderCount=" + leaderCount + ", leaderCount=" + leaderCount +
", regionName='" + regionName + '\'' + ", regionName='" + regionName + '\'' +
'}'; '}';