8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 20:22:12 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

TopicManagerServiceImpl的modifyTopicByOp没有return ResultStatus.SUCCESS;

Browse Source
This commit is contained in:
didi
2021-12-21 18:06:23 +08:00
parent 19b7f6ad8c
commit b327359183
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
View File

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