package config

assembly.xml

@@ -0,0 +1,37 @@
+<assembly
+    xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2 http://maven.apache.org/xsd/assembly-1.1.2.xsd">
+    <id>rocketmq-reput</id>
+    <formats>
+        <format>tar.gz</format>
+    </formats>
+
+    <fileSets>
+        <fileSet>
+            <directory>${project.basedir}/src/main/resources</directory>
+            <outputDirectory>config</outputDirectory>
+            <includes>
+                <include>*.yml</include>
+            </includes>
+        </fileSet>
+
+        <fileSet>
+            <directory>${project.basedir}/bin</directory>
+            <lineEnding>unix</lineEnding>
+            <includes>
+                <include>*.sh</include>
+            </includes>
+            <outputDirectory>bin</outputDirectory>
+            <fileMode>0755</fileMode>
+        </fileSet>
+
+        <fileSet>
+            <directory>${project.basedir}/target</directory>
+            <outputDirectory>lib</outputDirectory>
+            <includes>
+                <include>*.jar</include>
+            </includes>
+        </fileSet>
+    </fileSets>
+</assembly>

bin/shutdown.sh

@@ -0,0 +1,8 @@
+#!/bin/bash
+
+SCRIPT_DIR=`dirname $0`
+PROJECT_DIR="$SCRIPT_DIR/.."
+# 不要修改进程标记，作为进程属性关闭使用
+PROCESS_FLAG="kafka-console-ui-process-flag:${PROJECT_DIR}"
+pkill -f $PROCESS_FLAG
+echo 'Stop Kafka-console-ui!'

bin/start.sh

@@ -0,0 +1,20 @@
+#!/bin/bash
+
+# 设置jvm堆大小及栈大小，栈大小最少设置为256K，不要小于这个值，比如设置为128，太小了
+JAVA_MEM_OPTS="-Xmx512m -Xms512m -Xmn256m -Xss256k"
+
+SCRIPT_DIR=`dirname $0`
+PROJECT_DIR="$SCRIPT_DIR/.."
+CONF_FILE="$PROJECT_DIR/config/application.yml"
+TARGET="$PROJECT_DIR/lib/kafka-console-ui.jar"
+# 日志目录，默认为当前工程目录下
+# 这个是错误输出，如果启动命令有误，输出到这个文件，应用日志不会输出到error.out，应用日志输出到上面的rocketmq-reput.log中
+ERROR_OUT="$PROJECT_DIR/error.out"
+# 不要修改进程标记，作为进程属性关闭使用，如果要修改，请把stop.sh里的该属性的值保持一致
+PROCESS_FLAG="kafka-console-ui-process-flag:${PROJECT_DIR}"
+
+JAVA_OPTS="$JAVA_OPTS $JAVA_MEM_OPTS"
+
+nohup java -jar $JAVA_OPTS $TARGET --spring.config.location="$CONF_FILE" --logging.home="$PROJECT_DIR" $PROCESS_FLAG 1>/dev/null 2>$ERROR_OUT &
+
+echo "Kafka-console-ui Started!"

package.sh

@@ -1,3 +1,3 @@
 #!/bin/bash
 
-mvn clean scala:compile compile package -Dmaven.test.skip=true
+mvn clean scala:compile compile package -Dmaven.test.skip=true -Pdeploy

pom.xml

@@ -22,6 +22,7 @@
         <frontend-maven-plugin.version>1.11.0</frontend-maven-plugin.version>
         <compiler.version>1.8</compiler.version>
         <kafka.version>2.8.0</kafka.version>
+        <maven.assembly.plugin.version>3.0.0</maven.assembly.plugin.version>
     </properties>
     <dependencies>
         <dependency>
@@ -162,16 +163,16 @@
                         <version>${frontend-maven-plugin.version}</version>
                         <configuration>
                             <workingDirectory>${ui.path}</workingDirectory>
-                            <nodeVersion>v8.17.0</nodeVersion>
+                            <nodeVersion>v14.16.0</nodeVersion>
                             <downloadRoot>http://npm.taobao.org/mirrors/node/</downloadRoot>
                         </configuration>
                         <executions>
-                            <!--					<execution>-->
+                            <execution>
-                            <!--						<id>install node and npm</id>-->
+                                <id>install node and npm</id>
-                            <!--						<goals>-->
+                                <goals>
-                            <!--							<goal>install-node-and-npm</goal>-->
+                                    <goal>install-node-and-npm</goal>
-                            <!--						</goals>-->
+                                </goals>
-                            <!--					</execution>-->
+                            </execution>
                             <execution>
                                 <id>npm install</id>
                                 <goals>
@@ -210,6 +211,30 @@
                             </resources>
                         </configuration>
                     </plugin>
+                    <plugin>
+                        <artifactId>maven-assembly-plugin</artifactId>
+                        <version>${maven.assembly.plugin.version}</version>
+                        <executions>
+                            <execution>
+                                <id>kafka-console-ui</id>
+                                <phase>package</phase>
+                                <goals>
+                                    <goal>single</goal>
+                                </goals>
+                                <configuration>
+                                    <descriptors>
+                                        <descriptor>${project.basedir}/assembly.xml</descriptor>
+                                    </descriptors>
+                                </configuration>
+                            </execution>
+                        </executions>
+                        <configuration>
+                            <attach>true</attach>
+                            <tarLongFileMode>posix</tarLongFileMode>
+                            <runOnlyAtExecutionRoot>false</runOnlyAtExecutionRoot>
+                            <appendAssemblyId>false</appendAssemblyId>
+                        </configuration>
+                    </plugin>
                 </plugins>
             </build>
         </profile>

src/main/resources/application.yml

@@ -1,7 +1,8 @@
 server:
   port: 7766
   servlet:
-    context-path: /kafka-console
+    # 不要修改context-path
+    context-path: /
 
 kafka:
   config:
@@ -16,6 +17,13 @@ kafka:
     admin-password: admin
     # 启动自动创建配置的超级管理员用户
     admin-create: true
+    # broker连接的zk地址
     zookeeper-addr: localhost:2181
     sasl-jaas-config: org.apache.kafka.common.security.scram.ScramLoginModule required username="${kafka.config.admin-username}" password="${kafka.config.admin-password}";
 
+spring:
+  application:
+    name: kafka-console-ui
+
+logging:
+  home: ./

src/main/resources/logback-test.xml

@@ -1,24 +1,62 @@
 <configuration debug="false">
+    <springProperty scope="context" name="APPLICATION_NAME" source="spring.application.name"/>
+    <springProperty scope="context" name="LOGGING_HOME" source="logging.home"/>
 
-    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+    <!-- 日志目录   -->
-        <layout class="ch.qos.logback.classic.PatternLayout">
+    <property name="LOG_HOME" value="${LOGGING_HOME}/logs"/>
-            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>
+    <!--    日志文件名-->
-        </layout>
+    <property name="APP_NAME" value="${APPLICATION_NAME:-.}"/>
+
+    <!--    使用默认的输出格式-->
+    <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
+    <include resource="org/springframework/boot/logging/logback/console-appender.xml"/>
+
+    <appender name="DefaultAppender"
+              class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_HOME}/${APP_NAME}.log</file>
+        <append>true</append>
+        <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${APP_NAME}.%i.log.gz</fileNamePattern>
+            <minIndex>1</minIndex>
+            <maxIndex>10</maxIndex>
+        </rollingPolicy>
+        <!--        基于大小的滚动策略-->
+        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
+            <maxFileSize>20MB</maxFileSize>
+        </triggeringPolicy>
+        <encoder>
+            <pattern>${FILE_LOG_PATTERN}</pattern>
+            <charset class="java.nio.charset.Charset">UTF-8</charset>
+        </encoder>
+    </appender>
+    <!--    异步输出-->
+    <appender name="AsyncFileAppender" class="ch.qos.logback.classic.AsyncAppender">
+        <appender-ref ref="DefaultAppender"/>
     </appender>
 
-    <root level="INFO">
+    <root>
-        <appender-ref ref="STDOUT"/>
+        <level value="INFO"/>
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="AsyncFileAppender"/>
     </root>
 
     <logger name="org.apache.kafka.clients.consumer" level="warn" additivity="false">
-        <appender-ref ref="STDOUT"/>
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="AsyncFileAppender"/>
+    </logger>
+
+    <logger name="org.apache.kafka.clients.consumer" level="warn" additivity="false">
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="AsyncFileAppender"/>
     </logger>
 
     <logger name="org.apache.kafka.clients.admin.AdminClientConfig" level="warn" additivity="false">
-        <appender-ref ref="STDOUT"/>
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="AsyncFileAppender"/>
     </logger>
 
     <logger name="ch.qos.logback" level="error" additivity="false">
-        <appender-ref ref="STDOUT"/>
+        <appender-ref ref="CONSOLE"/>
+        <appender-ref ref="AsyncFileAppender"/>
     </logger>
 </configuration>

ui/.env

@@ -0,0 +1,3 @@
+NODE_ENV=production
+VUE_APP_PREVIEW=false
+VUE_APP_API_BASE_URL=/

ui/.env.development

@@ -0,0 +1,3 @@
+NODE_ENV=development
+VUE_APP_PREVIEW=true
+VUE_APP_API_BASE_URL=/kafka-console

ui/src/utils/request.js

@@ -5,7 +5,7 @@ import { VueAxios } from "./axios";
 // 创建 axios 实例
 const request = axios.create({
   // API 请求的默认前缀
-  baseURL: "/kafka-console",
+  baseURL: process.env.VUE_APP_API_BASE_URL,
   timeout: 10000, // 请求超时时间
 });
 

ui/src/views/acl/Acl.vue

@@ -201,10 +201,6 @@ export default {
       Object.assign(rowData, row);
       this.selectRow = rowData;
     },
-    cancel(e) {
-      console.log(e);
-      this.$message.error("Click on No");
-    },
     closeManageProducerAuthDialog() {
       this.openManageProducerAuthDialog = false;
       getAclList(this.data, this.queryParam);

ui/src/views/utils/ConfirmDialog.vue

@@ -1,36 +0,0 @@
-<template>
-  <a-popconfirm
-    :title="title"
-    ok-text="确认"
-    cancel-text="取消"
-    @confirm="confirm"
-    @cancel="cancel"
-  >
-  </a-popconfirm>
-</template>
-<script>
-export default {
-  name: "ConfirmDialog",
-  props: {
-    title: {
-      type: String,
-      default: "",
-    },
-    confirmEvent: {
-      default: "",
-    },
-  },
-  methods: {
-    confirm(e) {
-      console.log(e);
-      this.$message.success("Click on Yes");
-    },
-    cancel(e) {
-      console.log(e);
-      this.$message.error("Click on No");
-    },
-  },
-};
-</script>
-
-<style scoped></style>

ui/vue.config.js

@@ -5,9 +5,9 @@ module.exports = {
       "/kafka-console": {
         target: `${process.env.SW_PROXY_TARGET || "http://127.0.0.1:7766"}`,
         changeOrigin: true,
-        // pathRewrite: {
+        pathRewrite: {
-        //   '^/kafka-console': '/'
+          "^/kafka-console": "/",
-        // }
+        },
       },
     },
   },