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

统一pom包版本

Browse Source
This commit is contained in:
zengqiao
2020-09-29 17:25:04 +08:00
parent 788468054a
commit 1a4ef3d9c1
21 changed files with 265 additions and 213 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -109,3 +109,4 @@ web/src/main/resources/templates/*
*/out/* */out/*
*/dist/* */dist/*
.DS_Store .DS_Store
kafka-manager-web/src/main/resources/templates/*

2
docs/create_mysql_table.sql
View File

@@ -105,8 +105,6 @@ CREATE TABLE `cluster` (
`zookeeper` varchar(512) NOT NULL DEFAULT '' COMMENT 'zk地址', `zookeeper` varchar(512) NOT NULL DEFAULT '' COMMENT 'zk地址',
`bootstrap_servers` varchar(512) NOT NULL DEFAULT '' COMMENT 'server地址', `bootstrap_servers` varchar(512) NOT NULL DEFAULT '' COMMENT 'server地址',
`kafka_version` varchar(32) NOT NULL DEFAULT '' COMMENT 'kafka版本', `kafka_version` varchar(32) NOT NULL DEFAULT '' COMMENT 'kafka版本',
`idc` varchar(64) NOT NULL DEFAULT '' COMMENT '数据中心',
`mode` tinyint(4) NOT NULL DEFAULT '0' COMMENT '集群模式, 0:共享, 1:独享, 2:独立',
`security_properties` text COMMENT '安全认证参数', `security_properties` text COMMENT '安全认证参数',
`status` tinyint(4) NOT NULL DEFAULT '1' COMMENT ' 监控标记, 0表示未监控, 1表示监控中', `status` tinyint(4) NOT NULL DEFAULT '1' COMMENT ' 监控标记, 0表示未监控, 1表示监控中',
`gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',

57
kafka-manager-common/pom.xml
View File

@@ -15,15 +15,23 @@
</parent> </parent>
<properties> <properties>
<kafka-manager.revision>1.0.0-SNAPSHOT</kafka-manager.revision>
<maven.test.skip>true</maven.test.skip> <maven.test.skip>true</maven.test.skip>
<downloadSources>true</downloadSources> <downloadSources>true</downloadSources>
<java_source_version>1.8</java_source_version> <java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version> <java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding> <file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties> </properties>
<dependencies> <dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring-version}</version>
</dependency>
<!-- http --> <!-- http -->
<dependency> <dependency>
<groupId>org.apache.httpcomponents</groupId> <groupId>org.apache.httpcomponents</groupId>
@@ -42,33 +50,17 @@
<artifactId>httpmime</artifactId> <artifactId>httpmime</artifactId>
</dependency> </dependency>
<dependency> <!-- zookeeper -->
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
<version>1.9.3</version>
</dependency>
<dependency> <dependency>
<groupId>org.apache.curator</groupId> <groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId> <artifactId>curator-recipes</artifactId>
<version>2.10.0</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.apache.zookeeper</groupId> <groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId> <artifactId>zookeeper</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
</dependency>
<!-- swagger -->
<dependency> <dependency>
<groupId>io.springfox</groupId> <groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId> <artifactId>springfox-swagger2</artifactId>
@@ -80,18 +72,29 @@
<dependency> <dependency>
<groupId>io.swagger</groupId> <groupId>io.swagger</groupId>
<artifactId>swagger-annotations</artifactId> <artifactId>swagger-annotations</artifactId>
<version>1.5.13</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>5.0.9.RELEASE</version>
<scope>compile</scope>
</dependency> </dependency>
<!-- json -->
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>jackson-databind</artifactId>
<version>2.9.7</version> </dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency>
<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.apache.commons</groupId> <groupId>org.apache.commons</groupId>

25
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/entity/dto/rd/ClusterDTO.java
View File

@@ -24,12 +24,6 @@ public class ClusterDTO {
@ApiModelProperty(value="bootstrap地址") @ApiModelProperty(value="bootstrap地址")
private String bootstrapServers; private String bootstrapServers;
@ApiModelProperty(value="kafka版本")
private String kafkaVersion;
@ApiModelProperty(value="集群类型")
private Integer mode;
@ApiModelProperty(value="数据中心") @ApiModelProperty(value="数据中心")
private String idc; private String idc;
@@ -68,14 +62,6 @@ public class ClusterDTO {
this.bootstrapServers = bootstrapServers; this.bootstrapServers = bootstrapServers;
} }
public String getKafkaVersion() {
return kafkaVersion;
}
public void setKafkaVersion(String kafkaVersion) {
this.kafkaVersion = kafkaVersion;
}
public String getIdc() { public String getIdc() {
return idc; return idc;
} }
@@ -84,14 +70,6 @@ public class ClusterDTO {
this.idc = idc; this.idc = idc;
} }
public Integer getMode() {
return mode;
}
public void setMode(Integer mode) {
this.mode = mode;
}
public String getSecurityProperties() { public String getSecurityProperties() {
return securityProperties; return securityProperties;
} }
@@ -107,9 +85,7 @@ public class ClusterDTO {
", clusterName='" + clusterName + '\'' + ", clusterName='" + clusterName + '\'' +
", zookeeper='" + zookeeper + '\'' + ", zookeeper='" + zookeeper + '\'' +
", bootstrapServers='" + bootstrapServers + '\'' + ", bootstrapServers='" + bootstrapServers + '\'' +
", kafkaVersion='" + kafkaVersion + '\'' +
", idc='" + idc + '\'' + ", idc='" + idc + '\'' +
", mode='" + mode + '\'' +
", securityProperties='" + securityProperties + '\'' + ", securityProperties='" + securityProperties + '\'' +
'}'; '}';
} }
@@ -118,7 +94,6 @@ public class ClusterDTO {
if (ValidateUtils.isNull(clusterName) if (ValidateUtils.isNull(clusterName)
|| ValidateUtils.isNull(zookeeper) || ValidateUtils.isNull(zookeeper)
|| ValidateUtils.isNull(idc) || ValidateUtils.isNull(idc)
|| ValidateUtils.isNull(mode)
|| ValidateUtils.isNull(bootstrapServers) || ValidateUtils.isNull(bootstrapServers)
) { ) {
return false; return false;

38
kafka-manager-common/src/main/java/com/xiaojukeji/kafka/manager/common/entity/pojo/ClusterDO.java
View File

@@ -9,23 +9,19 @@ import java.util.Date;
public class ClusterDO implements Comparable<ClusterDO> { public class ClusterDO implements Comparable<ClusterDO> {
private Long id; private Long id;
private Integer status;
private Date gmtCreate;
private Date gmtModify;
private String clusterName; private String clusterName;
private String zookeeper; private String zookeeper;
private String bootstrapServers; private String bootstrapServers;
private Integer mode;
private String securityProperties; private String securityProperties;
private String kafkaVersion; private Integer status;
private Date gmtCreate;
private Date gmtModify;
public Long getId() { public Long getId() {
return id; return id;
@@ -83,14 +79,6 @@ public class ClusterDO implements Comparable<ClusterDO> {
this.bootstrapServers = bootstrapServers; this.bootstrapServers = bootstrapServers;
} }
public Integer getMode() {
return mode;
}
public void setMode(Integer mode) {
this.mode = mode;
}
public String getSecurityProperties() { public String getSecurityProperties() {
return securityProperties; return securityProperties;
} }
@@ -99,27 +87,17 @@ public class ClusterDO implements Comparable<ClusterDO> {
this.securityProperties = securityProperties; this.securityProperties = securityProperties;
} }
public String getKafkaVersion() {
return kafkaVersion;
}
public void setKafkaVersion(String kafkaVersion) {
this.kafkaVersion = kafkaVersion;
}
@Override @Override
public String toString() { public String toString() {
return "ClusterDO{" + return "ClusterDO{" +
"id=" + id + "id=" + id +
", status=" + status +
", gmtCreate=" + gmtCreate +
", gmtModify=" + gmtModify +
", clusterName='" + clusterName + '\'' + ", clusterName='" + clusterName + '\'' +
", zookeeper='" + zookeeper + '\'' + ", zookeeper='" + zookeeper + '\'' +
", bootstrapServers='" + bootstrapServers + '\'' + ", bootstrapServers='" + bootstrapServers + '\'' +
", mode=" + mode +
", securityProperties='" + securityProperties + '\'' + ", securityProperties='" + securityProperties + '\'' +
", kafkaVersion='" + kafkaVersion + '\'' + ", status=" + status +
", gmtCreate=" + gmtCreate +
", gmtModify=" + gmtModify +
'}'; '}';
} }

6
kafka-manager-console/pom.xml
View File

@@ -2,13 +2,15 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-console</artifactId>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<version>2.0.0-SNAPSHOT</version> <version>2.0.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-console</artifactId>
<build> <build>
<plugins> <plugins>
<plugin> <plugin>

24
kafka-manager-core/pom.xml
View File

@@ -24,14 +24,14 @@
<java_target_version>1.8</java_target_version> <java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding> <file_encoding>UTF-8</file_encoding>
<spring-version>5.0.9.RELEASE</spring-version> <spring-version>5.1.3.RELEASE</spring-version>
</properties> </properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-dao</artifactId> <artifactId>kafka-manager-dao</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<!-- spring --> <!-- spring -->
@@ -56,10 +56,7 @@
<artifactId>javax.annotation-api</artifactId> <artifactId>javax.annotation-api</artifactId>
</dependency> </dependency>
<dependency> <!-- kafka -->
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
</dependency>
<dependency> <dependency>
<groupId>org.apache.kafka</groupId> <groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId> <artifactId>kafka_2.10</artifactId>
@@ -68,9 +65,10 @@
<groupId>org.apache.kafka</groupId> <groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId> <artifactId>kafka-clients</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.alibaba</groupId> <groupId>commons-lang</groupId>
<artifactId>fastjson</artifactId> <artifactId>commons-lang</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>junit</groupId> <groupId>junit</groupId>
@@ -80,23 +78,25 @@
<dependency> <dependency>
<groupId>commons-codec</groupId> <groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId> <artifactId>commons-codec</artifactId>
<version>1.11</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.eclipse.jetty</groupId> <groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-util</artifactId> <artifactId>jetty-util</artifactId>
<version>9.2.24.v20180105</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.github.ben-manes.caffeine</groupId> <groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId> <artifactId>caffeine</artifactId>
<version>2.6.2</version> </dependency>
<!-- json -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>jackson-databind</artifactId>
<version>2.9.7</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

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

@@ -288,7 +288,6 @@ public class ClusterServiceImpl implements ClusterService {
dto.setBootstrapServers(clusterDO.getBootstrapServers()); dto.setBootstrapServers(clusterDO.getBootstrapServers());
dto.setKafkaVersion(physicalClusterMetadataManager.getKafkaVersion(clusterDO.getId())); dto.setKafkaVersion(physicalClusterMetadataManager.getKafkaVersion(clusterDO.getId()));
dto.setIdc(configUtils.getIdc()); dto.setIdc(configUtils.getIdc());
dto.setMode(clusterDO.getMode());
dto.setSecurityProperties(clusterDO.getSecurityProperties()); dto.setSecurityProperties(clusterDO.getSecurityProperties());
dto.setStatus(clusterDO.getStatus()); dto.setStatus(clusterDO.getStatus());
dto.setGmtCreate(clusterDO.getGmtCreate()); dto.setGmtCreate(clusterDO.getGmtCreate());

3
kafka-manager-dao/pom.xml
View File

@@ -29,13 +29,12 @@
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-common</artifactId> <artifactId>kafka-manager-common</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.mybatis.spring.boot</groupId> <groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId> <artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>mysql</groupId> <groupId>mysql</groupId>

7
kafka-manager-dao/src/main/resources/mapper/ClusterDao.xml
View File

@@ -11,9 +11,7 @@
<result column="cluster_name" property="clusterName" /> <result column="cluster_name" property="clusterName" />
<result column="zookeeper" property="zookeeper" /> <result column="zookeeper" property="zookeeper" />
<result column="bootstrap_servers" property="bootstrapServers" /> <result column="bootstrap_servers" property="bootstrapServers" />
<result column="mode" property="mode" />
<result column="security_properties" property="securityProperties" /> <result column="security_properties" property="securityProperties" />
<result column="kafka_version" property="kafkaVersion" />
</resultMap> </resultMap>
<insert id="insert" <insert id="insert"
@@ -21,9 +19,9 @@
useGeneratedKeys="true" useGeneratedKeys="true"
keyProperty="id"> keyProperty="id">
INSERT INTO cluster ( INSERT INTO cluster (
cluster_name, zookeeper, bootstrap_servers, mode, security_properties cluster_name, zookeeper, bootstrap_servers, security_properties
) VALUES ( ) VALUES (
#{clusterName}, #{zookeeper}, #{bootstrapServers}, #{mode}, #{securityProperties} #{clusterName}, #{zookeeper}, #{bootstrapServers}, #{securityProperties}
) )
</insert> </insert>
@@ -31,7 +29,6 @@
UPDATE cluster SET UPDATE cluster SET
cluster_name=#{clusterName}, cluster_name=#{clusterName},
bootstrap_servers=#{bootstrapServers}, bootstrap_servers=#{bootstrapServers},
mode=#{mode},
security_properties=#{securityProperties}, security_properties=#{securityProperties},
status=#{status} status=#{status}
WHERE id = #{id} WHERE id = #{id}

15
kafka-manager-extends/kafka-manager-account/pom.xml
View File

@@ -5,6 +5,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-account</artifactId> <artifactId>kafka-manager-account</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
@@ -17,12 +18,17 @@
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-common</artifactId> <artifactId>kafka-manager-common</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-dao</artifactId> <artifactId>kafka-manager-dao</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency>
<dependency>
<groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId>
<version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
@@ -33,10 +39,5 @@
<groupId>com.github.ben-manes.caffeine</groupId> <groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId> <artifactId>caffeine</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId>
<version>2.0.0-SNAPSHOT</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

17
kafka-manager-extends/kafka-manager-bpm/pom.xml
View File

@@ -2,37 +2,38 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-bpm</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<version>2.0.0-SNAPSHOT</version> <version>2.0.0-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath> <relativePath>../../pom.xml</relativePath>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-bpm</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-common</artifactId> <artifactId>kafka-manager-common</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-dao</artifactId> <artifactId>kafka-manager-dao</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId> <artifactId>kafka-manager-core</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-account</artifactId> <artifactId>kafka-manager-account</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

59
kafka-manager-extends/kafka-manager-kcm/pom.xml
View File

@@ -2,6 +2,11 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-kcm</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
@@ -9,49 +14,59 @@
<relativePath>../../pom.xml</relativePath> <relativePath>../../pom.xml</relativePath>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-kcm</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<description> <description>
kafka cluster manager Kafka集群任务管理
</description> </description>
<properties>
<!-- maven properties -->
<maven.test.skip>true</maven.test.skip>
<downloadSources>true</downloadSources>
<!-- compiler settings properties -->
<java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-dao</artifactId> <artifactId>kafka-manager-dao</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-common</artifactId> <artifactId>kafka-manager-common</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.slf4j</groupId> <groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId> <artifactId>slf4j-api</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>5.0.9.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.9.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.9.RELEASE</version>
</dependency>
<dependency> <dependency>
<groupId>junit</groupId> <groupId>junit</groupId>
<artifactId>junit</artifactId> <artifactId>junit</artifactId>
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring-version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring-version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring-version}</version>
</dependency>
</dependencies> </dependencies>
</project> </project>

20
kafka-manager-extends/kafka-manager-monitor/pom.xml
View File

@@ -15,11 +15,24 @@
<relativePath>../../pom.xml</relativePath> <relativePath>../../pom.xml</relativePath>
</parent> </parent>
<properties>
<!-- maven properties -->
<maven.test.skip>true</maven.test.skip>
<downloadSources>true</downloadSources>
<!-- compiler settings properties -->
<java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-dao</artifactId> <artifactId>kafka-manager-dao</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
@@ -42,15 +55,16 @@
<groupId>commons-lang</groupId> <groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId> <artifactId>commons-lang</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId> <artifactId>spring-beans</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId> <artifactId>spring-context</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

43
kafka-manager-extends/kafka-manager-notify/pom.xml
View File

@@ -2,36 +2,53 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-notify</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<version>2.0.0-SNAPSHOT</version> <version>2.0.0-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath> <relativePath>../../pom.xml</relativePath>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-notify</artifactId> <properties>
<!-- maven properties -->
<maven.test.skip>true</maven.test.skip>
<downloadSources>true</downloadSources>
<!-- compiler settings properties -->
<java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-common</artifactId> <artifactId>kafka-manager-common</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency>
<dependency>
<groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId>
<version>${parent.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId> <artifactId>spring-context</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency>
<dependency>
<groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId>
<version>2.0.0-SNAPSHOT</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

33
kafka-manager-extends/kafka-manager-openapi/pom.xml
View File

@@ -2,6 +2,11 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>kafka-manager-openapi</artifactId>
<version>2.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>kafka-manager</artifactId> <artifactId>kafka-manager</artifactId>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
@@ -9,27 +14,39 @@
<relativePath>../../pom.xml</relativePath> <relativePath>../../pom.xml</relativePath>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <properties>
<artifactId>kafka-manager-openapi</artifactId> <!-- maven properties -->
<version>2.0.0-SNAPSHOT</version> <maven.test.skip>true</maven.test.skip>
<packaging>jar</packaging> <downloadSources>true</downloadSources>
<description></description>
<!-- compiler settings properties -->
<java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties>
<description>
开放接口
</description>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId> <artifactId>kafka-manager-core</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-bpm</artifactId> <artifactId>kafka-manager-bpm</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId> <artifactId>spring-context</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

23
kafka-manager-task/pom.xml
View File

@@ -14,32 +14,45 @@
<version>2.0.0-SNAPSHOT</version> <version>2.0.0-SNAPSHOT</version>
</parent> </parent>
<properties>
<!-- maven properties -->
<maven.test.skip>true</maven.test.skip>
<downloadSources>true</downloadSources>
<!-- compiler settings properties -->
<java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<file_encoding>UTF-8</file_encoding>
<spring-version>5.1.3.RELEASE</spring-version>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId> <artifactId>kafka-manager-core</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-kcm</artifactId> <artifactId>kafka-manager-kcm</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-monitor</artifactId> <artifactId>kafka-manager-monitor</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-bpm</artifactId> <artifactId>kafka-manager-bpm</artifactId>
<version>2.0.0-SNAPSHOT</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId> <artifactId>spring-context</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

39
kafka-manager-web/pom.xml
View File

@@ -16,9 +16,8 @@
<properties> <properties>
<java_source_version>1.8</java_source_version> <java_source_version>1.8</java_source_version>
<java_target_version>1.8</java_target_version> <java_target_version>1.8</java_target_version>
<!--<swagger2.version>2.7.0</swagger2.version>-->
<springframework.boot.version>2.1.1.RELEASE</springframework.boot.version> <springframework.boot.version>2.1.1.RELEASE</springframework.boot.version>
<spring-version>5.1.3.RELEASE</spring-version>
<failOnMissingWebXml>false</failOnMissingWebXml> <failOnMissingWebXml>false</failOnMissingWebXml>
</properties> </properties>
@@ -26,27 +25,27 @@
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-core</artifactId> <artifactId>kafka-manager-core</artifactId>
<version>${project.parent.version}</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-kcm</artifactId> <artifactId>kafka-manager-kcm</artifactId>
<version>${project.parent.version}</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-task</artifactId> <artifactId>kafka-manager-task</artifactId>
<version>${project.parent.version}</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-monitor</artifactId> <artifactId>kafka-manager-monitor</artifactId>
<version>${project.parent.version}</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
<artifactId>kafka-manager-openapi</artifactId> <artifactId>kafka-manager-openapi</artifactId>
<version>${project.parent.version}</version> <version>${parent.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.xiaojukeji.kafka</groupId> <groupId>com.xiaojukeji.kafka</groupId>
@@ -104,7 +103,7 @@
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId> <artifactId>spring-context-support</artifactId>
<version>5.0.9.RELEASE</version> <version>${spring-version}</version>
</dependency> </dependency>
</dependencies> </dependencies>
@@ -122,30 +121,6 @@
</execution> </execution>
</executions> </executions>
</plugin> </plugin>
<!--<plugin>-->
<!--<artifactId>maven-resources-plugin</artifactId>-->
<!--<version>2.5</version>-->
<!--<executions>-->
<!--<execution>-->
<!--<id>copy-resources</id>-->
<!--<phase>validate</phase>-->
<!--<goals>-->
<!--<goal>copy-resources</goal>-->
<!--</goals>-->
<!--<configuration>-->
<!--<outputDirectory>src/main/resources/templates</outputDirectory>-->
<!--<overwrite>true</overwrite>-->
<!--<resources>-->
<!--<resource>-->
<!--<directory>../console/dist</directory>-->
<!--<filtering>true</filtering>-->
<!--</resource>-->
<!--</resources>-->
<!--</configuration>-->
<!--</execution>-->
<!--</executions>-->
<!--</plugin>-->
</plugins> </plugins>
</build> </build>
</project> </project>

6
kafka-manager-web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/op/OpClusterController.java
View File

@@ -27,13 +27,13 @@ public class OpClusterController {
@ApiOperation(value = "接入集群") @ApiOperation(value = "接入集群")
@RequestMapping(value = "clusters", method = RequestMethod.POST) @RequestMapping(value = "clusters", method = RequestMethod.POST)
@ResponseBody @ResponseBody
public Result addNew(@RequestBody ClusterDTO reqObj) { public Result addNew(@RequestBody ClusterDTO dto) {
if (ValidateUtils.isNull(reqObj) || !reqObj.legal()) { if (ValidateUtils.isNull(dto) || !dto.legal()) {
return Result.buildFrom(ResultStatus.PARAM_ILLEGAL); return Result.buildFrom(ResultStatus.PARAM_ILLEGAL);
} }
return Result.buildFrom( return Result.buildFrom(
clusterService.addNew( clusterService.addNew(
ClusterModelConverter.convert2ClusterDO(reqObj), ClusterModelConverter.convert2ClusterDO(dto),
SpringTool.getUserName() SpringTool.getUserName()
) )
); );

55
pom.xml
View File

@@ -11,14 +11,14 @@
<parent> <parent>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId> <artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version> <!-- 莫要修改该版本, 否则可能会导致自自定义的schedule不生效 --> <version>2.1.1.RELEASE</version> <!-- 莫要修改该版本, 否则可能会导致自自定义的schedule不生效 -->
<!--<relativePath/>--> <!--<relativePath/>-->
</parent> </parent>
<properties> <properties>
<kafka-manager.revision>1.0.0-SNAPSHOT</kafka-manager.revision> <kafka-manager.revision>2.0.0-SNAPSHOT</kafka-manager.revision>
<jackson.version>2.9.7</jackson.version>
<swagger2.version>2.7.0</swagger2.version> <swagger2.version>2.7.0</swagger2.version>
<swagger.version>1.5.13</swagger.version>
<!-- maven properties --> <!-- maven properties -->
<maven.test.skip>true</maven.test.skip> <maven.test.skip>true</maven.test.skip>
@@ -57,6 +57,11 @@
<artifactId>springfox-swagger-ui</artifactId> <artifactId>springfox-swagger-ui</artifactId>
<version>${swagger2.version}</version> <version>${swagger2.version}</version>
</dependency> </dependency>
<dependency>
<groupId>io.swagger</groupId>
<artifactId>swagger-annotations</artifactId>
<version>${swagger.version}</version>
</dependency>
<!-- javax --> <!-- javax -->
<dependency> <dependency>
@@ -109,6 +114,11 @@
<artifactId>mybatis-spring</artifactId> <artifactId>mybatis-spring</artifactId>
<version>1.3.2</version> <version>1.3.2</version>
</dependency> </dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<!-- kafka --> <!-- kafka -->
<dependency> <dependency>
@@ -128,12 +138,19 @@
<version>0.10.2.2</version> <version>0.10.2.2</version>
</dependency> </dependency>
<!-- commons --> <!-- json -->
<dependency> <dependency>
<groupId>com.alibaba</groupId> <groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId> <artifactId>fastjson</artifactId>
<version>1.2.70</version> <version>1.2.70</version>
</dependency> </dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.10.5</version>
</dependency>
<!-- commons -->
<dependency> <dependency>
<groupId>org.apache.zookeeper</groupId> <groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId> <artifactId>zookeeper</artifactId>
@@ -176,6 +193,36 @@
<artifactId>commons-pool2</artifactId> <artifactId>commons-pool2</artifactId>
<version>2.6.2</version> <version>2.6.2</version>
</dependency> </dependency>
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.11</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-util</artifactId>
<version>9.2.24.v20180105</version>
</dependency>
<dependency>
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
<version>2.6.2</version>
</dependency>
<dependency>
<groupId>commons-beanutils</groupId>
<artifactId>commons-beanutils</artifactId>
<version>1.9.3</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.10.0</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>
</project> </project>