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;