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 a25115ef..25e9af8d 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 @@ -419,6 +419,7 @@ public class TopicManagerServiceImpl implements TopicManagerService { authorityDO.setTopicName(topicName); authorityDO.setAccess(TopicAuthorityEnum.READ_WRITE.getCode()); authorityService.addAuthority(authorityDO); + return ResultStatus.SUCCESS; } catch (Exception e) { LOGGER.error("modify topic failed, clusterId:{} topicName:{} description:{} operator:{} ", clusterId, topicName, description, operator, e);