From 21904a860916e662c0908a5859be61dcffb0b14d Mon Sep 17 00:00:00 2001 From: didi <1643482336@qq.com> Date: Fri, 24 Dec 2021 14:41:39 +0800 Subject: [PATCH] =?UTF-8?q?`TopicManagerServiceImpl=E7=9A=84addAuthority?= =?UTF-8?q?=E4=B8=AD=E4=BD=BF=E7=94=A8=E7=9A=84=E6=98=AFgetId=EF=BC=8C?= =?UTF-8?q?=E5=BA=94=E8=AF=A5=E6=98=AFgetAppId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../manager/service/service/impl/TopicManagerServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java index 25e9af8d..a30599f8 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java @@ -632,7 +632,7 @@ public class TopicManagerServiceImpl implements TopicManagerService { // 该用户无应用,需要先申请应用 return ResultStatus.APP_NOT_EXIST; } - List appIds = appDOs.stream().map(AppDO::getId).collect(Collectors.toList()); + List appIds = appDOs.stream().map(AppDO::getAppId).collect(Collectors.toList()); if (!appIds.contains(authorityDO.getAppId())) { // 入参中的appId,该用户未拥有 return ResultStatus.APP_NOT_EXIST;