支持通过配置关闭Swagger

README.md

@@ -136,7 +136,7 @@
 
 👍 我们正在组建国内最大，最权威的 **[Kafka中文社区](https://z.didi.cn/5gSF9)**
 
-在这里你可以结交各大互联网的 Kafka大佬 以及 6200+ Kafka爱好者，一起实现知识共享，实时掌控最新行业资讯，期待 👏   您的加入中～ https://z.didi.cn/5gSF9
+在这里你可以结交各大互联网的 Kafka大佬 以及 4000+ Kafka爱好者，一起实现知识共享，实时掌控最新行业资讯，期待 👏   您的加入中～ https://z.didi.cn/5gSF9
 
 有问必答~！ 互动有礼~！
 
@@ -146,7 +146,7 @@ PS: 提问请尽量把问题一次性描述清楚，并告知环境信息情况
 
 **`2、微信群`**
 
-微信加群：添加`PynnXie` 的微信号备注KnowStreaming加群。
+微信加群：添加`PenceXie` 的微信号备注KnowStreaming加群。
 <br/>
 
 加群之前有劳点一下 star，一个小小的 star 是对KnowStreaming作者们努力建设社区的动力。

km-console/packages/layout-clusters-fe/src/pages/TopicList/ExpandPartition.tsx

@@ -44,7 +44,7 @@ const ExpandPartition = (props: { record: any; onConfirm: () => void }) => {
 
     setLoading(true);
     const metricParams = {
-      aggType: 'sum',
+      aggType: 'avg',
       endTime: Math.round(endStamp),
       metricsNames: ['BytesIn', 'BytesOut'],
       startTime: Math.round(startStamp),

km-console/pom.xml

@@ -32,6 +32,8 @@
                         <configuration>
                             <nodeVersion>v12.22.12</nodeVersion>
                             <npmVersion>6.14.16</npmVersion>
+                            <nodeDownloadRoot>https://npmmirror.com/mirrors/node/</nodeDownloadRoot>
+                            <npmDownloadRoot>https://registry.npmmirror.com/npm/-/</npmDownloadRoot>
                         </configuration>
                     </execution>
                     <execution>

km-persistence/src/main/resources/es/dsl/TopicMetricESDAO/getAggListMetrics

@@ -17,13 +17,6 @@
             }
           }
         },
-        {
-          "term": {
-            "brokerAgg" : {
-              "value": "1"
-            }
-          }
-        },
         {
           "range": {
             "timestamp": {

km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/config/WebConfig.java

@@ -6,6 +6,7 @@ import com.xiaojukeji.know.streaming.km.common.constant.ApiPrefix;
 import com.xiaojukeji.know.streaming.km.common.utils.GitPropUtil;
 import com.xiaojukeji.know.streaming.km.rest.interceptor.PermissionInterceptor;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.*;
@@ -24,6 +25,9 @@ public class WebConfig implements WebMvcConfigurer {
 
     private static final String FE_INDEX_PAGE_HTML = "layout/index";
 
+    @Value(value = "${swagger.enabled:true}")
+    private Boolean swaggerEnabled;
+
     @Override
     public void addViewControllers(ViewControllerRegistry registry) {
         // FE-首页
@@ -69,7 +73,7 @@ public class WebConfig implements WebMvcConfigurer {
                         RequestHandlerSelectors.basePackage("com.didiglobal.logi.security.controller")))
                 .paths(PathSelectors.any())
                 .build()
-                .enable(true);
+                .enable(swaggerEnabled != null && swaggerEnabled);
     }
 
     private ApiInfo apiInfo() {

km-rest/src/main/resources/application.yml

@@ -115,4 +115,7 @@ management:
         descriptions: true
         enabled: true
     tags:
-      application: know-streaming
+      application: know-streaming
+
+swagger:
+  enabled: true