From e204023b1f221dfac906135a0c14b74cfed56638 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Thu, 9 Feb 2023 17:03:28 +0800 Subject: [PATCH] =?UTF-8?q?[Feature]=E5=A2=9E=E5=8A=A0=E6=94=AF=E6=8C=81To?= =?UTF-8?q?pic=E5=A4=8D=E5=88=B6=E7=9A=84=E9=9B=86=E7=BE=A4=E5=88=97?= =?UTF-8?q?=E8=A1=A8=E6=8E=A5=E5=8F=A3(#899)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mirror/MirrorClusterController.java | 37 +++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorClusterController.java diff --git a/km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorClusterController.java b/km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorClusterController.java new file mode 100644 index 00000000..f4d2f855 --- /dev/null +++ b/km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/enterprise/mirror/MirrorClusterController.java @@ -0,0 +1,37 @@ +package com.xiaojukeji.know.streaming.km.rest.api.v3.enterprise.mirror; + +import com.xiaojukeji.know.streaming.km.common.bean.entity.cluster.ClusterPhy; +import com.xiaojukeji.know.streaming.km.common.bean.entity.result.Result; +import com.xiaojukeji.know.streaming.km.common.bean.vo.cluster.ClusterPhyBaseVO; +import com.xiaojukeji.know.streaming.km.common.constant.ApiPrefix; +import com.xiaojukeji.know.streaming.km.common.constant.Constant; +import com.xiaojukeji.know.streaming.km.common.utils.ConvertUtil; +import com.xiaojukeji.know.streaming.km.core.service.cluster.ClusterPhyService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; +import java.util.stream.Collectors; + +/** + * @author zengqiao + * @date 22/12/12 + */ +@Api(tags = Constant.SWAGGER_API_TAG_PREFIX + "Mirror-集群-相关接口(REST)") +@RestController +@RequestMapping(ApiPrefix.API_V3_HA_MIRROR_PREFIX) +public class MirrorClusterController { + + @Autowired + private ClusterPhyService clusterPhyService; + + @ApiOperation(value = "集群列表(支持Mirror)", notes = "") + @GetMapping(value = "physical-clusters/basic") + @ResponseBody + public Result> listClusters() { + List clusterPhyList = clusterPhyService.listAllClusters().stream().filter(item -> item.getKafkaVersion().contains("2.5.0-d-")).collect(Collectors.toList()); + return Result.buildSuc(ConvertUtil.list2List(clusterPhyList, ClusterPhyBaseVO.class)); + } +}