From f331a6d144b31e1db576e22056ea7098729bef58 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Tue, 27 Sep 2022 18:43:22 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8E=E7=AB=AF=E8=A1=A5=E5=85=85Kafka?= =?UTF-8?q?=E9=9B=86=E7=BE=A4=E8=BF=90=E8=A1=8C=E6=A8=A1=E5=BC=8F=E5=AD=97?= =?UTF-8?q?=E6=AE=B5=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../streaming/km/common/bean/vo/cluster/ClusterPhyBaseVO.java | 3 +++ 1 file changed, 3 insertions(+) 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; }