diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/cluster/ClusterPhyBaseVO.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/cluster/ClusterPhyBaseVO.java index d0960d27..e0707e20 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/cluster/ClusterPhyBaseVO.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/vo/cluster/ClusterPhyBaseVO.java @@ -39,4 +39,7 @@ public class ClusterPhyBaseVO extends BaseTimeVO { @ApiModelProperty(value="集群的kafka版本", example = "2.5.1") protected String kafkaVersion; + + @ApiModelProperty(value="集群的运行模式", example = "2:raft模式,其他是ZK模式") + private Integer runState; }