Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
DiDi
kafka-manager
提交
892e195f
K
kafka-manager
项目概览
DiDi
/
kafka-manager
10 个月 前同步成功
通知
59
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,发现更多精彩内容 >>
提交
892e195f
编写于
5月 18, 2021
作者:
Z
zengqiao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
code format
上级
c5b1bed7
变更
30
隐藏空白更改
内联
并排
Showing
30 changed file
with
88 addition
and
94 deletion
+88
-94
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/ApiLevelEnum.java
...xiaojukeji/kafka/manager/common/bizenum/ApiLevelEnum.java
+0
-19
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/ConsumeHealthEnum.java
...ukeji/kafka/manager/common/bizenum/ConsumeHealthEnum.java
+0
-8
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/DBStatusEnum.java
...xiaojukeji/kafka/manager/common/bizenum/DBStatusEnum.java
+5
-2
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/IDCEnum.java
.../com/xiaojukeji/kafka/manager/common/bizenum/IDCEnum.java
+0
-8
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/KafkaBrokerRoleEnum.java
...eji/kafka/manager/common/bizenum/KafkaBrokerRoleEnum.java
+0
-4
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/KafkaClientEnum.java
...ojukeji/kafka/manager/common/bizenum/KafkaClientEnum.java
+0
-8
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/OffsetResetTypeEnum.java
...eji/kafka/manager/common/bizenum/OffsetResetTypeEnum.java
+7
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/OperationStatusEnum.java
...eji/kafka/manager/common/bizenum/OperationStatusEnum.java
+8
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/PeakFlowStatusEnum.java
...keji/kafka/manager/common/bizenum/PeakFlowStatusEnum.java
+2
-10
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/RebalanceDimensionEnum.java
.../kafka/manager/common/bizenum/RebalanceDimensionEnum.java
+8
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TaskStatusEnum.java
...aojukeji/kafka/manager/common/bizenum/TaskStatusEnum.java
+1
-12
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TaskStatusReassignEnum.java
.../kafka/manager/common/bizenum/TaskStatusReassignEnum.java
+1
-6
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicAuthorityEnum.java
...keji/kafka/manager/common/bizenum/TopicAuthorityEnum.java
+8
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicExpiredStatusEnum.java
.../kafka/manager/common/bizenum/TopicExpiredStatusEnum.java
+8
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicOffsetChangedEnum.java
.../kafka/manager/common/bizenum/TopicOffsetChangedEnum.java
+0
-8
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
.../manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
+0
-8
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ApiLevelContent.java
...jukeji/kafka/manager/common/constant/ApiLevelContent.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ApiPrefix.java
...m/xiaojukeji/kafka/manager/common/constant/ApiPrefix.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ConfigConstant.java
...ojukeji/kafka/manager/common/constant/ConfigConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/Constant.java
...om/xiaojukeji/kafka/manager/common/constant/Constant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/KafkaConstant.java
...aojukeji/kafka/manager/common/constant/KafkaConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/KafkaMetricsCollections.java
...afka/manager/common/constant/KafkaMetricsCollections.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/LogConstant.java
...xiaojukeji/kafka/manager/common/constant/LogConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/LoginConstant.java
...aojukeji/kafka/manager/common/constant/LoginConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/SystemCodeConstant.java
...eji/kafka/manager/common/constant/SystemCodeConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TopicCreationConstant.java
.../kafka/manager/common/constant/TopicCreationConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TopicSampleConstant.java
...ji/kafka/manager/common/constant/TopicSampleConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TrickLoginConstant.java
...eji/kafka/manager/common/constant/TrickLoginConstant.java
+3
-0
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/zookeeper/ZkPathUtil.java
...xiaojukeji/kafka/manager/common/zookeeper/ZkPathUtil.java
+3
-0
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/BrokerServiceImpl.java
...kafka/manager/service/service/impl/BrokerServiceImpl.java
+1
-1
未找到文件。
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/ApiLevelEnum.java
已删除
100644 → 0
浏览文件 @
c5b1bed7
package
com.xiaojukeji.kafka.manager.common.bizenum
;
/**
* @author zengqiao
* @date 20/7/27
*/
public
enum
ApiLevelEnum
{
LEVEL_0
(
0
),
LEVEL_1
(
1
),
LEVEL_2
(
2
),
LEVEL_3
(
3
)
;
private
int
level
;
ApiLevelEnum
(
int
level
)
{
this
.
level
=
level
;
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/ConsumeHealthEnum.java
浏览文件 @
892e195f
...
...
@@ -24,18 +24,10 @@ public enum ConsumeHealthEnum {
return
code
;
}
public
void
setCode
(
Integer
code
)
{
this
.
code
=
code
;
}
public
String
getMessage
()
{
return
message
;
}
public
void
setMessage
(
String
message
)
{
this
.
message
=
message
;
}
@Override
public
String
toString
()
{
return
"ConsumeHealthEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/DBStatusEnum.java
浏览文件 @
892e195f
...
...
@@ -19,7 +19,10 @@ public enum DBStatusEnum {
return
status
;
}
public
void
setStatus
(
int
status
)
{
this
.
status
=
status
;
@Override
public
String
toString
()
{
return
"DBStatusEnum{"
+
"status="
+
status
+
'}'
;
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/IDCEnum.java
浏览文件 @
892e195f
...
...
@@ -21,18 +21,10 @@ public enum IDCEnum {
return
idc
;
}
public
void
setIdc
(
String
idc
)
{
this
.
idc
=
idc
;
}
public
String
getName
()
{
return
name
;
}
public
void
setName
(
String
name
)
{
this
.
name
=
name
;
}
@Override
public
String
toString
()
{
return
"IDCEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/KafkaBrokerRoleEnum.java
浏览文件 @
892e195f
...
...
@@ -21,10 +21,6 @@ public enum KafkaBrokerRoleEnum {
return
role
;
}
public
void
setRole
(
String
role
)
{
this
.
role
=
role
;
}
@Override
public
String
toString
()
{
return
"KafkaBrokerRoleEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/KafkaClientEnum.java
浏览文件 @
892e195f
...
...
@@ -24,18 +24,10 @@ public enum KafkaClientEnum {
return
code
;
}
public
void
setCode
(
Integer
code
)
{
this
.
code
=
code
;
}
public
String
getName
()
{
return
name
;
}
public
void
setName
(
String
name
)
{
this
.
name
=
name
;
}
@Override
public
String
toString
()
{
return
"KafkaClientEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/OffsetResetTypeEnum.java
浏览文件 @
892e195f
...
...
@@ -18,4 +18,11 @@ public enum OffsetResetTypeEnum {
public
Integer
getCode
()
{
return
code
;
}
@Override
public
String
toString
()
{
return
"OffsetResetTypeEnum{"
+
"code="
+
code
+
'}'
;
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/OperationStatusEnum.java
浏览文件 @
892e195f
...
...
@@ -27,4 +27,12 @@ public enum OperationStatusEnum {
public
String
getMessage
()
{
return
message
;
}
@Override
public
String
toString
()
{
return
"OperationStatusEnum{"
+
"code="
+
code
+
", message='"
+
message
+
'\''
+
'}'
;
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/PeakFlowStatusEnum.java
浏览文件 @
892e195f
...
...
@@ -15,9 +15,9 @@ public enum PeakFlowStatusEnum {
;
p
ublic
Integer
code
;
p
rivate
Integer
code
;
p
ublic
String
message
;
p
rivate
String
message
;
PeakFlowStatusEnum
(
Integer
code
,
String
message
)
{
this
.
code
=
code
;
...
...
@@ -28,18 +28,10 @@ public enum PeakFlowStatusEnum {
return
code
;
}
public
void
setCode
(
Integer
code
)
{
this
.
code
=
code
;
}
public
String
getMessage
()
{
return
message
;
}
public
void
setMessage
(
String
message
)
{
this
.
message
=
message
;
}
@Override
public
String
toString
()
{
return
"PeakFlowStatusEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/RebalanceDimensionEnum.java
浏览文件 @
892e195f
...
...
@@ -29,4 +29,12 @@ public enum RebalanceDimensionEnum {
public
String
getMessage
()
{
return
message
;
}
@Override
public
String
toString
()
{
return
"RebalanceDimensionEnum{"
+
"code="
+
code
+
", message='"
+
message
+
'\''
+
'}'
;
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TaskStatusEnum.java
浏览文件 @
892e195f
...
...
@@ -43,18 +43,10 @@ public enum TaskStatusEnum {
return
code
;
}
public
void
setCode
(
Integer
code
)
{
this
.
code
=
code
;
}
public
String
getMessage
()
{
return
message
;
}
public
void
setMessage
(
String
message
)
{
this
.
message
=
message
;
}
@Override
public
String
toString
()
{
return
"TaskStatusEnum{"
+
...
...
@@ -64,9 +56,6 @@ public enum TaskStatusEnum {
}
public
static
Boolean
isFinished
(
Integer
code
)
{
if
(
code
>=
FINISHED
.
getCode
())
{
return
true
;
}
return
false
;
return
code
>=
FINISHED
.
getCode
();
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TaskStatusReassignEnum.java
浏览文件 @
892e195f
...
...
@@ -45,11 +45,6 @@ public enum TaskStatusReassignEnum {
}
public
static
Boolean
isFinished
(
Integer
code
)
{
if
(
SUCCEED
.
getCode
().
equals
(
code
)
||
FAILED
.
getCode
().
equals
(
code
)
||
CANCELED
.
getCode
().
equals
(
code
))
{
return
true
;
}
return
false
;
return
SUCCEED
.
getCode
().
equals
(
code
)
||
FAILED
.
getCode
().
equals
(
code
)
||
CANCELED
.
getCode
().
equals
(
code
);
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicAuthorityEnum.java
浏览文件 @
892e195f
...
...
@@ -33,4 +33,12 @@ public enum TopicAuthorityEnum {
public
String
getMessage
()
{
return
message
;
}
@Override
public
String
toString
()
{
return
"TopicAuthorityEnum{"
+
"code="
+
code
+
", message='"
+
message
+
'\''
+
'}'
;
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicExpiredStatusEnum.java
浏览文件 @
892e195f
...
...
@@ -29,4 +29,12 @@ public enum TopicExpiredStatusEnum {
public
String
getMessage
()
{
return
message
;
}
@Override
public
String
toString
()
{
return
"TopicExpiredStatusEnum{"
+
"status="
+
status
+
", message='"
+
message
+
'\''
+
'}'
;
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/TopicOffsetChangedEnum.java
浏览文件 @
892e195f
...
...
@@ -23,18 +23,10 @@ public enum TopicOffsetChangedEnum {
return
code
;
}
public
void
setCode
(
Integer
code
)
{
this
.
code
=
code
;
}
public
String
getMessage
()
{
return
message
;
}
public
void
setMessage
(
String
message
)
{
this
.
message
=
message
;
}
@Override
public
String
toString
()
{
return
"TopicOffsetChangedEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/bizenum/gateway/GatewayConfigKeyEnum.java
浏览文件 @
892e195f
...
...
@@ -26,18 +26,10 @@ public enum GatewayConfigKeyEnum {
return
configType
;
}
public
void
setConfigType
(
String
configType
)
{
this
.
configType
=
configType
;
}
public
String
getConfigName
()
{
return
configName
;
}
public
void
setConfigName
(
String
configName
)
{
this
.
configName
=
configName
;
}
@Override
public
String
toString
()
{
return
"GatewayConfigKeyEnum{"
+
...
...
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ApiLevelContent.java
浏览文件 @
892e195f
...
...
@@ -12,4 +12,7 @@ public class ApiLevelContent {
public
static
final
int
LEVEL_NORMAL_3
=
3
;
public
static
final
int
LEVEL_DEFAULT_4
=
4
;
private
ApiLevelContent
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ApiPrefix.java
浏览文件 @
892e195f
...
...
@@ -28,4 +28,7 @@ public class ApiPrefix {
// gateway
public
static
final
String
GATEWAY_API_V1_PREFIX
=
"/gateway"
+
API_V1_PREFIX
;
private
ApiPrefix
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/ConfigConstant.java
浏览文件 @
892e195f
...
...
@@ -30,4 +30,7 @@ public class ConfigConstant {
public
static
final
String
BROKER_CAPACITY_LIMIT_CONFIG_KEY
=
"BROKER_CAPACITY_LIMIT_CONFIG"
;
public
static
final
String
KAFKA_CLUSTER_DO_CONFIG_KEY
=
"KAFKA_CLUSTER_DO_CONFIG"
;
private
ConfigConstant
()
{
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/Constant.java
浏览文件 @
892e195f
...
...
@@ -45,4 +45,7 @@ public class Constant {
public
static
final
Integer
DEFAULT_MAX_CAL_TOPIC_EXPIRED_DAY
=
90
;
public
static
final
Integer
INVALID_CODE
=
-
1
;
private
Constant
()
{
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/KafkaConstant.java
浏览文件 @
892e195f
...
...
@@ -16,4 +16,7 @@ public class KafkaConstant {
public
static
final
String
CLIENT_VERSION_NAME_UNKNOWN
=
"unknown"
;
public
static
final
String
RETENTION_MS_KEY
=
"retention.ms"
;
private
KafkaConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/KafkaMetricsCollections.java
浏览文件 @
892e195f
...
...
@@ -39,4 +39,7 @@ public class KafkaMetricsCollections {
* Broker信息
*/
public
static
final
int
BROKER_VERSION
=
400
;
private
KafkaMetricsCollections
()
{
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/LogConstant.java
浏览文件 @
892e195f
...
...
@@ -10,4 +10,7 @@ public class LogConstant {
public
static
final
String
API_METRICS_LOGGER
=
"API_METRICS_LOGGER"
;
public
static
final
String
SCHEDULED_TASK_LOGGER
=
"SCHEDULED_TASK_LOGGER"
;
private
LogConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/LoginConstant.java
浏览文件 @
892e195f
...
...
@@ -11,4 +11,7 @@ public class LoginConstant {
public
static
final
String
COOKIE_CHINESE_USERNAME_KEY
=
"chineseName"
;
public
static
final
Integer
COOKIE_OR_SESSION_MAX_AGE_UNIT_MS
=
24
*
60
*
60
*
1000
;
private
LoginConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/SystemCodeConstant.java
浏览文件 @
892e195f
...
...
@@ -6,4 +6,7 @@ package com.xiaojukeji.kafka.manager.common.constant;
*/
public
class
SystemCodeConstant
{
public
static
final
String
KAFKA_MANAGER
=
"kafka-manager"
;
private
SystemCodeConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TopicCreationConstant.java
浏览文件 @
892e195f
...
...
@@ -54,4 +54,7 @@ public class TopicCreationConstant {
* 单次自动化审批, 最多允许的通过单子
*/
public
static
final
Integer
MAX_PASSED_ORDER_NUM_PER_TASK
=
200
;
private
TopicCreationConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TopicSampleConstant.java
浏览文件 @
892e195f
...
...
@@ -16,4 +16,7 @@ public class TopicSampleConstant {
public
static
final
Integer
MAX_TIMEOUT_UNIT_MS
=
10000
;
public
static
final
Integer
POLL_TIME_OUT_UNIT_MS
=
2000
;
public
static
final
Integer
MAX_DATA_LENGTH_UNIT_BYTE
=
2048
;
private
TopicSampleConstant
()
{
}
}
\ No newline at end of file
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/constant/TrickLoginConstant.java
浏览文件 @
892e195f
...
...
@@ -18,4 +18,7 @@ public class TrickLoginConstant {
*/
public
static
final
String
TRICK_LOGIN_SWITCH_ON
=
"on"
;
public
static
final
String
TRICK_LOGIN_SWITCH_OFF
=
"off"
;
private
TrickLoginConstant
()
{
}
}
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/zookeeper/ZkPathUtil.java
浏览文件 @
892e195f
...
...
@@ -119,4 +119,7 @@ public class ZkPathUtil {
public
static
String
getControllerCandidatePath
(
Integer
brokerId
)
{
return
D_CONTROLLER_CANDIDATES
+
ZOOKEEPER_SEPARATOR
+
brokerId
;
}
private
ZkPathUtil
()
{
}
}
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/BrokerServiceImpl.java
浏览文件 @
892e195f
...
...
@@ -91,7 +91,7 @@ public class BrokerServiceImpl implements BrokerService {
for
(
BrokerDO
brokerDO
:
brokerDOList
)
{
PeakFlowStatusEnum
peakFlowStatus
=
getPeakFlowStatus
(
brokerDO
.
getMaxAvgBytesIn
(),
peakFlow
);
peakFlowStatusMap
.
put
(
peakFlowStatus
.
code
,
peakFlowStatus
.
getCode
()
,
peakFlowStatusMap
.
getOrDefault
(
peakFlowStatus
.
getCode
(),
0
)
+
1
);
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录