Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
DiDi
kafka-manager
提交
0f408203
K
kafka-manager
项目概览
DiDi
/
kafka-manager
大约 1 年 前同步成功
通知
60
Star
6372
Fork
1229
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
K
kafka-manager
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
0f408203
编写于
4月 09, 2021
作者:
Z
zwOvO
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
删除无用import、删除无用代码
上级
b9bb1c77
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
2 addition
and
11 deletion
+2
-11
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/ClusterService.java
...ojukeji/kafka/manager/service/service/ClusterService.java
+0
-1
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java
...aojukeji/kafka/manager/service/service/RegionService.java
+0
-1
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/AdminServiceImpl.java
.../kafka/manager/service/service/impl/AdminServiceImpl.java
+0
-4
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ConsumerServiceImpl.java
...fka/manager/service/service/impl/ConsumerServiceImpl.java
+0
-1
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/normal/NormalAccountController.java
...er/web/api/versionone/normal/NormalAccountController.java
+1
-2
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/thirdpart/ThirdPartClusterController.java
.../api/versionone/thirdpart/ThirdPartClusterController.java
+1
-2
未找到文件。
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/ClusterService.java
浏览文件 @
0f408203
...
@@ -4,7 +4,6 @@ import com.xiaojukeji.kafka.manager.common.entity.Result;
...
@@ -4,7 +4,6 @@ import com.xiaojukeji.kafka.manager.common.entity.Result;
import
com.xiaojukeji.kafka.manager.common.entity.ResultStatus
;
import
com.xiaojukeji.kafka.manager.common.entity.ResultStatus
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.ClusterDetailDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.ClusterDetailDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.cluster.ControllerPreferredCandidate
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.cluster.ControllerPreferredCandidate
;
import
com.xiaojukeji.kafka.manager.common.entity.dto.op.ControllerPreferredCandidateDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.vo.normal.cluster.ClusterNameDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.vo.normal.cluster.ClusterNameDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterMetricsDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterMetricsDO
;
...
...
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/RegionService.java
浏览文件 @
0f408203
package
com.xiaojukeji.kafka.manager.service.service
;
package
com.xiaojukeji.kafka.manager.service.service
;
import
com.xiaojukeji.kafka.manager.common.entity.ResultStatus
;
import
com.xiaojukeji.kafka.manager.common.entity.ResultStatus
;
import
com.xiaojukeji.kafka.manager.common.entity.dto.rd.RegionDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.RegionDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.RegionDO
;
import
java.util.List
;
import
java.util.List
;
...
...
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/AdminServiceImpl.java
浏览文件 @
0f408203
...
@@ -340,10 +340,6 @@ public class AdminServiceImpl implements AdminService {
...
@@ -340,10 +340,6 @@ public class AdminServiceImpl implements AdminService {
@Override
@Override
public
ResultStatus
modifyTopicConfig
(
ClusterDO
clusterDO
,
String
topicName
,
Properties
properties
,
String
operator
)
{
public
ResultStatus
modifyTopicConfig
(
ClusterDO
clusterDO
,
String
topicName
,
Properties
properties
,
String
operator
)
{
ResultStatus
rs
=
TopicCommands
.
modifyTopicConfig
(
clusterDO
,
topicName
,
properties
);
ResultStatus
rs
=
TopicCommands
.
modifyTopicConfig
(
clusterDO
,
topicName
,
properties
);
if
(!
ResultStatus
.
SUCCESS
.
equals
(
rs
))
{
return
rs
;
}
return
rs
;
return
rs
;
}
}
}
}
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/ConsumerServiceImpl.java
浏览文件 @
0f408203
...
@@ -8,7 +8,6 @@ import com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumeDetailDTO;
...
@@ -8,7 +8,6 @@ import com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumeDetailDTO;
import
com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumerGroup
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumerGroup
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumerGroupSummary
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.consumer.ConsumerGroupSummary
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterDO
;
import
com.xiaojukeji.kafka.manager.common.entity.pojo.ClusterDO
;
import
com.xiaojukeji.kafka.manager.common.utils.ListUtils
;
import
com.xiaojukeji.kafka.manager.common.zookeeper.znode.brokers.TopicMetadata
;
import
com.xiaojukeji.kafka.manager.common.zookeeper.znode.brokers.TopicMetadata
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.PartitionOffsetDTO
;
import
com.xiaojukeji.kafka.manager.common.entity.ao.PartitionOffsetDTO
;
import
com.xiaojukeji.kafka.manager.common.exception.ConfigException
;
import
com.xiaojukeji.kafka.manager.common.exception.ConfigException
;
...
...
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/normal/NormalAccountController.java
浏览文件 @
0f408203
...
@@ -9,7 +9,6 @@ import com.xiaojukeji.kafka.manager.common.entity.vo.common.AccountSummaryVO;
...
@@ -9,7 +9,6 @@ import com.xiaojukeji.kafka.manager.common.entity.vo.common.AccountSummaryVO;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.common.utils.SpringTool
;
import
com.xiaojukeji.kafka.manager.common.utils.SpringTool
;
import
com.xiaojukeji.kafka.manager.common.constant.ApiPrefix
;
import
com.xiaojukeji.kafka.manager.common.constant.ApiPrefix
;
import
com.xiaojukeji.kafka.manager.web.api.versionone.gateway.GatewayHeartbeatController
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
io.swagger.annotations.ApiOperation
;
import
org.slf4j.Logger
;
import
org.slf4j.Logger
;
...
@@ -62,4 +61,4 @@ public class NormalAccountController {
...
@@ -62,4 +61,4 @@ public class NormalAccountController {
AccountRoleEnum
accountRoleEnum
=
accountService
.
getAccountRoleFromCache
(
username
);
AccountRoleEnum
accountRoleEnum
=
accountService
.
getAccountRoleFromCache
(
username
);
return
new
Result
<>(
new
AccountRoleVO
(
username
,
accountRoleEnum
.
getRole
()));
return
new
Result
<>(
new
AccountRoleVO
(
username
,
accountRoleEnum
.
getRole
()));
}
}
}
}
\ No newline at end of file
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/thirdpart/ThirdPartClusterController.java
浏览文件 @
0f408203
...
@@ -7,7 +7,6 @@ import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
...
@@ -7,7 +7,6 @@ import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
import
com.xiaojukeji.kafka.manager.common.entity.metrics.BrokerMetrics
;
import
com.xiaojukeji.kafka.manager.common.entity.metrics.BrokerMetrics
;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.common.utils.ValidateUtils
;
import
com.xiaojukeji.kafka.manager.common.zookeeper.znode.brokers.BrokerMetadata
;
import
com.xiaojukeji.kafka.manager.common.zookeeper.znode.brokers.BrokerMetadata
;
import
com.xiaojukeji.kafka.manager.openapi.common.vo.ThirdPartBrokerOverviewVO
;
import
com.xiaojukeji.kafka.manager.service.cache.PhysicalClusterMetadataManager
;
import
com.xiaojukeji.kafka.manager.service.cache.PhysicalClusterMetadataManager
;
import
com.xiaojukeji.kafka.manager.service.service.BrokerService
;
import
com.xiaojukeji.kafka.manager.service.service.BrokerService
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.Api
;
...
@@ -52,4 +51,4 @@ public class ThirdPartClusterController {
...
@@ -52,4 +51,4 @@ public class ThirdPartClusterController {
return
new
Result
<>(
underReplicated
.
equals
(
0
));
return
new
Result
<>(
underReplicated
.
equals
(
0
));
}
}
}
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录