启动后端(集群模式)

BladeX2024年6月1日大约 56 分钟quickstartcode

一、准备工作

导入git私服的 BladeX-Links 工程并点击maven刷新按钮下载依赖
- 后端核心依赖工程：blade-tool
- 如需拓展开发核心依赖工程，开发完毕后在blade-tool工程根目录执行mvn clean install命令便可刷新依赖
- 物联网平台底层基于BladeX架构开发，运行方式两者基本一致，在此之前推荐先查阅框架相关资料
- 特别详细的步骤，请看框架手册

二、启动后端系统服务 blade-server

前往BladeX-Links工程下的blade-server模块的application.yml配置文件，修改密钥保持与blade-broker一致

具体路径如下：BladeX-Links/blade-service/blade-server/src/main/resources/application.yml
需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的签名)：

#blade配置
blade:
  auth:
    #使用 @org.springblade.test.Sm2KeyGenerator 获取,用于国密sm2验签,需和前端保持一致
    public-key: 041cb889cccf335fcde7******************************3f5ac2b3542bbb903d84c07636550e8fe599aae4aef53a91cb77cbb1
    #使用 @org.springblade.test.Sm2KeyGenerator 获取,用于国密sm2解密,前端无需配置
    private-key: 73e345f2edfdf84b6***************88be564defa94c18515a7ccde602463
  token:
    #注意需要和blade-broker服务的sign-key保持一致
    #使用 @org.springblade.test.SignKeyGenerator 获取
    sign-key: 6klRvnw*************0TB4m51ZSh

具体路径如下：BladeX-Links-UI/src/config/website.js
需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的签名)：

auth: {
  // 使用 @org.springblade.test.Sm2KeyGenerator 获取,用于国密sm2验签,需和后端保持一致
  publicKey: '041cb889cccf335fcde7******************************3f5ac2b3542bbb903d84c07636550e8fe599aae4aef53a91cb77cbb1',
}

前往BladeX-Links工程下的blade-server模块的application-dev.yml配置文件，修改数据库、redis、influxdb、minio等配置

具体路径如下：BladeX-Links/blade-service/blade-server/src/main/resources/application-dev.yml
需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的ip、端口、用户名、密码等配置)：

#数据源配置
spring:
  data:
    redis:
      ##redis 单机环境配置
      host: 127.0.0.1
      port: 6379
      password:
      database: 0
      ssl:
        enabled: false
      ##redis 集群环境配置
      #cluster:
      #  nodes: 127.0.0.1:7001,127.0.0.1:7002,127.0.0.1:7003
      #  commandTimeout: 5000
  datasource:
    url: jdbc:mysql://localhost:3306/bladex_iot?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver

#时序数据库配置
tdengine:
  enabled: true     # 是否开启，多个时序库插件依赖同时导入可采用此参数配置，开启的时序库
  username: root
  password: taosdata
  database: links   # 库名，会自动建库
  jdbc-url: jdbc:TAOS-RS://127.0.0.1:6041?useSSL=false
  # 数据精度，默认：毫秒
  precision: ms
  # 数据保存的天数，默认：10年
  keep: 3650
  # 批量写入相关配置
  enable-batch: true # 开启批量写，默认：开
  batch-size: 1000   # 批次大小，默认：1000
  flush-duration: 1s # 批次写入时间，默认：1s 写入一次
  # 连接池相关配置，可按需求进行配置，建议改大一些
  initial-size: 8    # 初始化的连接数，默认：8
  max-active: 32     # 最大活跃连接数，默认：32
  min-idle: 8        # 最小活跃连接数，默认：8
  max-wait: -1       # 最大等待时间，默认：-1 不限制

#oss配置
oss:
  enabled: true
  name: minio
  tenant-mode: true
  endpoint: http://127.0.0.1:9000
  access-key: bladexadmin
  secret-key: bladexadmin
  bucket-name: bladex

#iot配置
blade:
  iot:
    # 外网ip或者域名
    mqtt-ip: 127.0.0.1
    # 外网可用的端口
    mqtt-port: 1883
    # broker服务ip或域名
    broker-ip: ${blade.iot.mqtt-ip}
    # broker服务端口
    broker-port: 8888

启动BladeX-Links工程下的blade-server模块的ServerApplication启动类，看到如下日志，则说明启动成功

/Library/Java/JavaVirtualMachines/zulu-17.jdk/Contents/Home/bin/java -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:62763,suspend=y,server=n --add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.lang.reflect=ALL-UNNAMED -agentpath:/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/idea_libasyncProfiler_dylib_temp_folder/libasyncProfiler.dylib=version,jfr,event=wall,interval=10ms,cstack=no,file=/Users/chill/IdeaSnapshots/ServerApplication_2025_03_06_223430.jfr,log=/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/ServerApplication_2025_03_06_223430.jfr.log.txt,logLevel=DEBUG -XX:TieredStopAtLevel=1 -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -Dmanagement.endpoints.jmx.exposure.include=* -javaagent:/Users/chill/Library/Caches/JetBrains/IntelliJIdea2024.3/captureAgent/debugger-agent.jar -Dkotlinx.coroutines.debug.enable.creation.stack.trace=false -Ddebugger.agent.enable.coroutines=true -Dkotlinx.coroutines.debug.enable.flows.stack.trace=true -Dkotlinx.coroutines.debug.enable.mutable.state.flows.stack.trace=true -Dfile.encoding=UTF-8 -classpath /Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-server/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-base/target/classes:/Users/chill/.m2/repository/org/springblade/blade-core-launch/4.5.0/blade-core-launch-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-web/3.2.12/spring-boot-starter-web-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-json/3.2.12/spring-boot-starter-json-3.2.12.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jdk8/2.15.4/jackson-datatype-jdk8-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/module/jackson-module-parameter-names/2.15.4/jackson-module-parameter-names-2.15.4.jar:/Users/chill/.m2/repository/org/springframework/spring-webmvc/6.1.15/spring-webmvc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-undertow/3.2.12/spring-boot-starter-undertow-3.2.12.jar:/Users/chill/.m2/repository/io/undertow/undertow-core/2.3.17.Final/undertow-core-2.3.17.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-api/3.8.16.Final/xnio-api-3.8.16.Final.jar:/Users/chill/.m2/repository/org/wildfly/common/wildfly-common/1.5.4.Final/wildfly-common-1.5.4.Final.jar:/Users/chill/.m2/repository/org/wildfly/client/wildfly-client-config/1.0.1.Final/wildfly-client-config-1.0.1.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-nio/3.8.16.Final/xnio-nio-3.8.16.Final.jar:/Users/chill/.m2/repository/org/jboss/threads/jboss-threads/3.5.0.Final/jboss-threads-3.5.0.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-servlet/2.3.17.Final/undertow-servlet-2.3.17.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-websockets-jsr/2.3.17.Final/undertow-websockets-jsr-2.3.17.Final.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-api/2.1.1/jakarta.websocket-api-2.1.1.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-client-api/2.1.1/jakarta.websocket-client-api-2.1.1.jar:/Users/chill/.m2/repository/org/apache/tomcat/embed/tomcat-embed-el/10.1.33/tomcat-embed-el-10.1.33.jar:/Users/chill/.m2/repository/jakarta/servlet/jakarta.servlet-api/6.0.0/jakarta.servlet-api-6.0.0.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-core/4.0.5/jaxb-core-4.0.5.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-impl/4.0.5/jaxb-impl-4.0.5.jar:/Users/chill/.m2/repository/javax/activation/activation/1.1.1/activation-1.1.1.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-mybatis/4.5.0/blade-starter-mybatis-4.5.0.jar:/Users/chill/.m2/repository/org/mybatis/mybatis/3.5.16/mybatis-3.5.16.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-spring/3.0.4/mybatis-spring-3.0.4.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus/3.5.8/mybatis-plus-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-annotation/3.5.8/mybatis-plus-annotation-3.5.8.jar:/Users/chill/.m2/repository/com/github/jsqlparser/jsqlparser/5.0/jsqlparser-5.0.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot-autoconfigure/3.5.8/mybatis-plus-spring-boot-autoconfigure-3.5.8.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-core/target/classes:/Users/chill/.m2/repository/org/springframework/spring-core/6.1.15/spring-core-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-jcl/6.1.15/spring-jcl-6.1.15.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-common/3.1.11/mica-mqttx-common-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-codec/3.1.11/mica-mqttx-codec-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-core/1.0.13/mica-net-core-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-utils/1.0.13/mica-net-utils-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-http/2.7.18.9/mica-http-2.7.18.9.jar:/Users/chill/.m2/repository/net/dreamlu/mica-core/2.7.18.9/mica-core-2.7.18.9.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.15.4/jackson-databind-2.15.4.jar:/Users/chill/.m2/repository/com/squareup/okhttp3/logging-interceptor/4.12.0/logging-interceptor-4.12.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-mail/3.2.12/spring-boot-starter-mail-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter/3.2.12/spring-boot-starter-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot/3.2.12/spring-boot-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/3.2.12/spring-boot-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-logging/3.2.12/spring-boot-starter-logging-3.2.12.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-classic/1.4.14/logback-classic-1.4.14.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-core/1.4.14/logback-core-1.4.14.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-to-slf4j/2.21.1/log4j-to-slf4j-2.21.1.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-api/2.21.1/log4j-api-2.21.1.jar:/Users/chill/.m2/repository/org/slf4j/jul-to-slf4j/2.0.16/jul-to-slf4j-2.0.16.jar:/Users/chill/.m2/repository/jakarta/annotation/jakarta.annotation-api/2.1.1/jakarta.annotation-api-2.1.1.jar:/Users/chill/.m2/repository/org/yaml/snakeyaml/2.2/snakeyaml-2.2.jar:/Users/chill/.m2/repository/org/springframework/spring-context-support/6.1.15/spring-context-support-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-beans/6.1.15/spring-beans-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-context/6.1.15/spring-context-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-expression/6.1.15/spring-expression-6.1.15.jar:/Users/chill/.m2/repository/org/eclipse/angus/jakarta.mail/2.0.3/jakarta.mail-2.0.3.jar:/Users/chill/.m2/repository/jakarta/activation/jakarta.activation-api/2.1.3/jakarta.activation-api-2.1.3.jar:/Users/chill/.m2/repository/org/eclipse/angus/angus-activation/2.0.2/angus-activation-2.0.2.jar:/Users/chill/.m2/repository/com/ibeetl/beetl/3.18.0.RELEASE/beetl-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/org/antlr/antlr4-runtime/4.9.2/antlr4-runtime-4.9.2.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-core/3.18.0.RELEASE/beetl-core-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-default-antlr4.9-support/3.18.0.RELEASE/beetl-default-antlr4.9-support-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-ext/3.18.0.RELEASE/beetl-ext-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-ui/4.5.0/knife4j-openapi3-ui-4.5.0.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-tdengine/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-api/target/classes:/Users/chill/.m2/repository/com/github/ben-manes/caffeine/caffeine/3.1.8/caffeine-3.1.8.jar:/Users/chill/.m2/repository/org/checkerframework/checker-qual/3.37.0/checker-qual-3.37.0.jar:/Users/chill/.m2/repository/com/google/errorprone/error_prone_annotations/2.21.1/error_prone_annotations-2.21.1.jar:/Users/chill/.m2/repository/com/taosdata/jdbc/taos-jdbcdriver/3.5.1/taos-jdbcdriver-3.5.1.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.15.4/jackson-datatype-jsr310-2.15.4.jar:/Users/chill/.m2/repository/com/google/guava/guava/33.1.0-jre/guava-33.1.0-jre.jar:/Users/chill/.m2/repository/com/google/guava/failureaccess/1.0.2/failureaccess-1.0.2.jar:/Users/chill/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/chill/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/Users/chill/.m2/repository/com/google/j2objc/j2objc-annotations/3.0.0/j2objc-annotations-3.0.0.jar:/Users/chill/.m2/repository/org/java-websocket/Java-WebSocket/1.5.4/Java-WebSocket-1.5.4.jar:/Users/chill/.m2/repository/org/springblade/blade-core-tool/4.5.0/blade-core-tool-4.5.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-annotations-jakarta/2.2.19/swagger-annotations-jakarta-2.2.19.jar:/Users/chill/.m2/repository/org/bouncycastle/bcprov-jdk18on/1.78.1/bcprov-jdk18on-1.78.1.jar:/Users/chill/.m2/repository/com/alibaba/druid/1.2.23/druid-1.2.23.jar:/Users/chill/.m2/repository/org/springblade/blade-core-boot/4.5.0/blade-core-boot-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-jdbc/3.2.12/spring-boot-starter-jdbc-3.2.12.jar:/Users/chill/.m2/repository/com/zaxxer/HikariCP/5.0.1/HikariCP-5.0.1.jar:/Users/chill/.m2/repository/org/springframework/spring-jdbc/6.1.15/spring-jdbc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-tx/6.1.15/spring-tx-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-cache/3.2.12/spring-boot-starter-cache-3.2.12.jar:/Users/chill/.m2/repository/org/springblade/blade-core-secure/4.5.0/blade-core-secure-4.5.0.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-impl/0.11.2/jjwt-impl-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-api/0.11.2/jjwt-api-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-jackson/0.11.2/jjwt-jackson-0.11.2.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-cache/4.5.0/blade-starter-cache-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-log/4.5.0/blade-starter-log-4.5.0.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot3-starter/3.5.8/mybatis-plus-spring-boot3-starter-3.5.8.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-typehandlers-jsr310/1.0.2/mybatis-typehandlers-jsr310-1.0.2.jar:/Users/chill/.m2/repository/net/sf/ehcache/ehcache/2.10.5/ehcache-2.10.5.jar:/Users/chill/.m2/repository/com/alibaba/druid-spring-boot-3-starter/1.2.23/druid-spring-boot-3-starter-1.2.23.jar:/Users/chill/.m2/repository/com/mysql/mysql-connector-j/8.3.0/mysql-connector-j-8.3.0.jar:/Users/chill/.m2/repository/com/google/protobuf/protobuf-java/3.25.1/protobuf-java-3.25.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-aop/3.2.12/spring-boot-starter-aop-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-aop/6.1.15/spring-aop-6.1.15.jar:/Users/chill/.m2/repository/org/aspectj/aspectjweaver/1.9.22.1/aspectjweaver-1.9.22.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-actuator/3.2.12/spring-boot-starter-actuator-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator-autoconfigure/3.2.12/spring-boot-actuator-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator/3.2.12/spring-boot-actuator-3.2.12.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-observation/1.12.13/micrometer-observation-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-commons/1.12.13/micrometer-commons-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-jakarta9/1.12.13/micrometer-jakarta9-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-core/1.12.13/micrometer-core-1.12.13.jar:/Users/chill/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.12/HdrHistogram-2.1.12.jar:/Users/chill/.m2/repository/org/latencyutils/LatencyUtils/2.0.3/LatencyUtils-2.0.3.jar:/Users/chill/.m2/repository/org/springframework/retry/spring-retry/2.0.10/spring-retry-2.0.10.jar:/Users/chill/.m2/repository/org/hibernate/validator/hibernate-validator/8.0.1.Final/hibernate-validator-8.0.1.Final.jar:/Users/chill/.m2/repository/jakarta/validation/jakarta.validation-api/3.0.2/jakarta.validation-api-3.0.2.jar:/Users/chill/.m2/repository/org/jboss/logging/jboss-logging/3.5.3.Final/jboss-logging-3.5.3.Final.jar:/Users/chill/.m2/repository/com/fasterxml/classmate/1.6.0/classmate-1.6.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-develop/4.5.0/blade-starter-develop-4.5.0.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-generator/3.5.8/mybatis-plus-generator-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-extension/3.5.8/mybatis-plus-extension-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-core/3.5.8/mybatis-plus-core-3.5.8.jar:/Users/chill/.m2/repository/org/apache/velocity/velocity-engine-core/2.4.1/velocity-engine-core-2.4.1.jar:/Users/chill/.m2/repository/org/apache/commons/commons-lang3/3.13.0/commons-lang3-3.13.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-oss/4.5.0/blade-starter-oss-4.5.0.jar:/Users/chill/.m2/repository/com/aliyun/oss/aliyun-sdk-oss/3.14.0/aliyun-sdk-oss-3.14.0.jar:/Users/chill/.m2/repository/org/jdom/jdom2/2.0.6.1/jdom2-2.0.6.1.jar:/Users/chill/.m2/repository/org/codehaus/jettison/jettison/1.1/jettison-1.1.jar:/Users/chill/.m2/repository/stax/stax-api/1.0.1/stax-api-1.0.1.jar:/Users/chill/.m2/repository/com/aliyun/aliyun-java-sdk-ram/3.1.0/aliyun-java-sdk-ram-3.1.0.jar:/Users/chill/.m2/repository/com/aliyun/aliyun-java-sdk-kms/2.11.0/aliyun-java-sdk-kms-2.11.0.jar:/Users/chill/.m2/repository/io/minio/minio/8.3.7/minio-8.3.7.jar:/Users/chill/.m2/repository/com/carrotsearch/thirdparty/simple-xml-safe/2.7.1/simple-xml-safe-2.7.1.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.15.4/jackson-annotations-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.15.4/jackson-core-2.15.4.jar:/Users/chill/.m2/repository/org/apache/commons/commons-compress/1.21/commons-compress-1.21.jar:/Users/chill/.m2/repository/org/xerial/snappy/snappy-java/1.1.8.4/snappy-java-1.1.8.4.jar:/Users/chill/.m2/repository/com/qiniu/qiniu-java-sdk/7.9.4/qiniu-java-sdk-7.9.4.jar:/Users/chill/.m2/repository/com/qcloud/cos_api/5.6.147/cos_api-5.6.147.jar:/Users/chill/.m2/repository/joda-time/joda-time/2.9.9/joda-time-2.9.9.jar:/Users/chill/.m2/repository/com/tencentcloudapi/tencentcloud-sdk-java-kms/3.1.213/tencentcloud-sdk-java-kms-3.1.213.jar:/Users/chill/.m2/repository/com/tencentcloudapi/tencentcloud-sdk-java-common/3.1.213/tencentcloud-sdk-java-common-3.1.213.jar:/Users/chill/.m2/repository/com/squareup/okhttp/logging-interceptor/2.7.5/logging-interceptor-2.7.5.jar:/Users/chill/.m2/repository/com/squareup/okhttp/okhttp/2.7.5/okhttp-2.7.5.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-report/4.5.0/blade-starter-report-4.5.0.jar:/Users/chill/.m2/repository/com/bstek/ureport/ureport2-console/2.2.9/ureport2-console-2.2.9.jar:/Users/chill/.m2/repository/org/apache/velocity/velocity/1.7/velocity-1.7.jar:/Users/chill/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/Users/chill/.m2/repository/commons-lang/commons-lang/2.4/commons-lang-2.4.jar:/Users/chill/.m2/repository/com/bstek/ureport/ureport2-font/2.0.1/ureport2-font-2.0.1.jar:/Users/chill/.m2/repository/com/bstek/ureport/ureport2-core/2.2.9/ureport2-core-2.2.9.jar:/Users/chill/.m2/repository/commons-beanutils/commons-beanutils-core/1.8.3/commons-beanutils-core-1.8.3.jar:/Users/chill/.m2/repository/dom4j/dom4j/1.6.1/dom4j-1.6.1.jar:/Users/chill/.m2/repository/xml-apis/xml-apis/1.0.b2/xml-apis-1.0.b2.jar:/Users/chill/.m2/repository/org/springframework/spring-web/6.1.15/spring-web-6.1.15.jar:/Users/chill/.m2/repository/com/itextpdf/itextpdf/5.5.13/itextpdf-5.5.13.jar:/Users/chill/.m2/repository/org/apache/poi/poi-ooxml/4.1.2/poi-ooxml-4.1.2.jar:/Users/chill/.m2/repository/com/github/virtuald/curvesapi/1.06/curvesapi-1.06.jar:/Users/chill/.m2/repository/org/apache/poi/poi-scratchpad/4.1.2/poi-scratchpad-4.1.2.jar:/Users/chill/.m2/repository/org/apache/poi/ooxml-schemas/1.4/ooxml-schemas-1.4.jar:/Users/chill/.m2/repository/org/apache/xmlbeans/xmlbeans/3.0.1/xmlbeans-3.0.1.jar:/Users/chill/.m2/repository/com/google/zxing/core/3.3.1/core-3.3.1.jar:/Users/chill/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.11/jackson-mapper-asl-1.9.11.jar:/Users/chill/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.11/jackson-core-asl-1.9.11.jar:/Users/chill/.m2/repository/commons-io/commons-io/2.5/commons-io-2.5.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-social/4.5.0/blade-starter-social-4.5.0.jar:/Users/chill/.m2/repository/me/zhyd/oauth/JustAuth/1.16.6/JustAuth-1.16.6.jar:/Users/chill/.m2/repository/com/xkcoding/http/simple-http/1.0.5/simple-http-1.0.5.jar:/Users/chill/.m2/repository/com/alibaba/fastjson/2.0.47/fastjson-2.0.47.jar:/Users/chill/.m2/repository/com/alibaba/fastjson2/fastjson2-extension/2.0.47/fastjson2-extension-2.0.47.jar:/Users/chill/.m2/repository/com/alibaba/fastjson2/fastjson2/2.0.47/fastjson2-2.0.47.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpclient/4.5.14/httpclient-4.5.14.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-datascope/4.5.0/blade-starter-datascope-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-swagger/4.5.0/blade-starter-swagger-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-jakarta-spring-boot-starter/4.5.0/knife4j-openapi3-jakarta-spring-boot-starter-4.5.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-ui/2.3.0/springdoc-openapi-starter-webmvc-ui-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-api/2.3.0/springdoc-openapi-starter-webmvc-api-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-common/2.3.0/springdoc-openapi-starter-common-2.3.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-core-jakarta/2.2.19/swagger-core-jakarta-2.2.19.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-models-jakarta/2.2.19/swagger-models-jakarta-2.2.19.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.15.4/jackson-dataformat-yaml-2.15.4.jar:/Users/chill/.m2/repository/org/webjars/swagger-ui/5.10.3/swagger-ui-5.10.3.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-tenant/4.5.0/blade-starter-tenant-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-redis/4.5.0/blade-starter-redis-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-data-redis/3.2.12/spring-boot-starter-data-redis-3.2.12.jar:/Users/chill/.m2/repository/io/lettuce/lettuce-core/6.3.2.RELEASE/lettuce-core-6.3.2.RELEASE.jar:/Users/chill/.m2/repository/io/netty/netty-common/4.1.115.Final/netty-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-handler/4.1.115.Final/netty-handler-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-resolver/4.1.115.Final/netty-resolver-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-buffer/4.1.115.Final/netty-buffer-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.115.Final/netty-transport-native-unix-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-codec/4.1.115.Final/netty-codec-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport/4.1.115.Final/netty-transport-4.1.115.Final.jar:/Users/chill/.m2/repository/io/projectreactor/reactor-core/3.6.12/reactor-core-3.6.12.jar:/Users/chill/.m2/repository/org/reactivestreams/reactive-streams/1.0.4/reactive-streams-1.0.4.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-redis/3.2.12/spring-data-redis-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-keyvalue/3.2.12/spring-data-keyvalue-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-commons/3.2.12/spring-data-commons-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-oxm/6.1.15/spring-oxm-6.1.15.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-core/1.6.0/protostuff-core-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-api/1.6.0/protostuff-api-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-runtime/1.6.0/protostuff-runtime-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-collectionschema/1.6.0/protostuff-collectionschema-1.6.0.jar:/Users/chill/.m2/repository/com/squareup/okhttp3/okhttp/4.12.0/okhttp-4.12.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio/3.6.0/okio-3.6.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio-jvm/3.6.0/okio-jvm-3.6.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-common/1.9.25/kotlin-stdlib-common-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk8/1.9.25/kotlin-stdlib-jdk8-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib/1.9.25/kotlin-stdlib-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/annotations/13.0/annotations-13.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk7/1.9.25/kotlin-stdlib-jdk7-1.9.25.jar:/Users/chill/.m2/repository/com/github/whvcse/easy-captcha/1.6.2/easy-captcha-1.6.2.jar:/Users/chill/.m2/repository/com/alibaba/easyexcel/3.3.4/easyexcel-3.3.4.jar:/Users/chill/.m2/repository/com/alibaba/easyexcel-core/3.3.4/easyexcel-core-3.3.4.jar:/Users/chill/.m2/repository/com/alibaba/easyexcel-support/3.3.4/easyexcel-support-3.3.4.jar:/Users/chill/.m2/repository/org/apache/poi/poi/4.1.2/poi-4.1.2.jar:/Users/chill/.m2/repository/org/apache/commons/commons-collections4/4.4/commons-collections4-4.4.jar:/Users/chill/.m2/repository/org/apache/commons/commons-math3/3.6.1/commons-math3-3.6.1.jar:/Users/chill/.m2/repository/com/zaxxer/SparseBitSet/1.2/SparseBitSet-1.2.jar:/Users/chill/.m2/repository/org/apache/poi/poi-ooxml-schemas/4.1.2/poi-ooxml-schemas-4.1.2.jar:/Users/chill/.m2/repository/org/apache/commons/commons-csv/1.12.0/commons-csv-1.12.0.jar:/Users/chill/.m2/repository/org/ehcache/ehcache/3.10.8/ehcache-3.10.8.jar:/Users/chill/.m2/repository/javax/cache/cache-api/1.1.1/cache-api-1.1.1.jar:/Users/chill/.m2/repository/org/slf4j/slf4j-api/2.0.16/slf4j-api-2.0.16.jar:/Users/chill/.m2/repository/com/aliyun/aliyun-java-sdk-core/4.5.30/aliyun-java-sdk-core-4.5.30.jar:/Users/chill/.m2/repository/com/google/code/gson/gson/2.10.1/gson-2.10.1.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpcore/4.4.16/httpcore-4.4.16.jar:/Users/chill/.m2/repository/commons-logging/commons-logging/1.2/commons-logging-1.2.jar:/Users/chill/.m2/repository/javax/xml/bind/jaxb-api/2.3.1/jaxb-api-2.3.1.jar:/Users/chill/.m2/repository/javax/activation/javax.activation-api/1.2.0/javax.activation-api-1.2.0.jar:/Users/chill/.m2/repository/org/glassfish/jaxb/jaxb-runtime/4.0.5/jaxb-runtime-4.0.5.jar:/Users/chill/.m2/repository/org/glassfish/jaxb/jaxb-core/4.0.5/jaxb-core-4.0.5.jar:/Users/chill/.m2/repository/org/glassfish/jaxb/txw2/4.0.5/txw2-4.0.5.jar:/Users/chill/.m2/repository/com/sun/istack/istack-commons-runtime/4.1.2/istack-commons-runtime-4.1.2.jar:/Users/chill/.m2/repository/org/bouncycastle/bcprov-jdk15on/1.68/bcprov-jdk15on-1.68.jar:/Users/chill/.m2/repository/org/jacoco/org.jacoco.agent/0.8.7/org.jacoco.agent-0.8.7-runtime.jar:/Users/chill/.m2/repository/org/ini4j/ini4j/0.5.4/ini4j-0.5.4.jar:/Users/chill/.m2/repository/io/opentracing/opentracing-api/0.33.0/opentracing-api-0.33.0.jar:/Users/chill/.m2/repository/io/opentracing/opentracing-util/0.33.0/opentracing-util-0.33.0.jar:/Users/chill/.m2/repository/io/opentracing/opentracing-noop/0.33.0/opentracing-noop-0.33.0.jar:/Users/chill/.m2/repository/com/github/qcloudsms/qcloudsms/1.0.6/qcloudsms-1.0.6.jar:/Users/chill/.m2/repository/org/json/json/20170516/json-20170516.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpmime/4.5.3/httpmime-4.5.3.jar:/Users/chill/.m2/repository/commons-codec/commons-codec/1.16.1/commons-codec-1.16.1.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-core/4.5.0/knife4j-core-4.5.0.jar:/Users/chill/.m2/repository/jakarta/xml/bind/jakarta.xml.bind-api/4.0.2/jakarta.xml.bind-api-4.0.2.jar:/Users/chill/.m2/repository/org/projectlombok/lombok/1.18.36/lombok-1.18.36.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar org.springblade.ServerApplication
Connected to the target VM, address: '127.0.0.1:62763', transport: 'socket'
----启动中，读取到的环境变量:[dev]，jar地址:[/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-server/target/classes/]----
  ____  _           _     __   __    _     _       _
|  _ \| |         | |    \ \ / /   | |   (_)     | |
| |_) | | __ _  __| | ___ \ V /    | |    _ _ __ | | _____
|  _ <| |/ _` |/ _` |/ _ \ > <     | |   | | '_ \| |/ / __|
| |_) | | (_| | (_| |  __// . \    | |___| | | | |   <\__ \
|____/|_|\__,_|\__,_|\___/_/ \_\   |_____|_|_| |_|_|\_\___/

:: BladeX :: blade-iot:dev :: Running SpringBoot 3.2.12 ::

2025-03-06 22:34:31.508  INFO 35491 --- [kground-preinit] o.h.validator.internal.util.Version      : HV000001: Hibernate Validator 8.0.1.Final
2025-03-06 22:34:31.533  INFO 35491 --- [           main] org.springblade.ServerApplication        : Starting ServerApplication using Java 17.0.10 with PID 35491 (/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-server/target/classes started by chill in /Users/chill/Workspaces/product/BladeX-Links)
2025-03-06 22:34:31.533 DEBUG 35491 --- [           main] org.springblade.ServerApplication        : Running with Spring Boot v3.2.12, Spring v6.1.15
2025-03-06 22:34:31.534  INFO 35491 --- [           main] org.springblade.ServerApplication        : The following 1 profile is active: "dev"
2025-03-06 22:34:32.278  INFO 35491 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
2025-03-06 22:34:32.280  INFO 35491 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2025-03-06 22:34:32.324  INFO 35491 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 38 ms. Found 0 Redis repository interfaces.
2025-03-06 22:34:32.397  WARN 35491 --- [           main] o.m.s.mapper.ClassPathMapperScanner      : Skipping MapperFactoryBean with name 'deviceCoreMapper' and 'org.springblade.iot.core.mapper.DeviceCoreMapper' mapperInterface. Bean already defined with the same name!
2025-03-06 22:34:32.451  INFO 35491 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor init.
2025-03-06 22:34:32.477  INFO 35491 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor process @BladePropertySource bean.
2025-03-06 22:34:33.072  INFO 35491 --- [           main] io.undertow.servlet                      : Initializing Spring embedded WebApplicationContext
2025-03-06 22:34:33.072  INFO 35491 --- [           main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1519 ms
2025-03-06 22:34:33.235  INFO 35491 --- [           main] c.a.d.s.b.a.DruidDataSourceAutoConfigure : Init DruidDataSource
2025-03-06 22:34:33.380  INFO 35491 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-1} inited
2025-03-06 22:34:34.883  INFO 35491 --- [           main] o.s.c.redis.pubsub.RedisPubSubPublisher  : RPubSubPublisher init success.
2025-03-06 22:34:36.401  INFO 35491 --- [           main] o.s.c.r.pubsub.RPubSubListenerDetector   : Found @RPubSubListener on bean:iotTslCacheConfiguration.CacheUpdateListener method:public void org.springblade.iot.tsdb.config.IotTslCacheConfiguration$CacheUpdateListener.tslUpdateEvent(org.springblade.core.redis.pubsub.RPubSubEvent)
2025-03-06 22:34:36.964  INFO 35491 --- [           main] o.s.core.boot.config.RetryConfiguration  : configServerRetryInterceptor: Changing backOffOptions to initial: 1000, multiplier: 1.2, maxInterval: 5000
2025-03-06 22:34:36.990  INFO 35491 --- [           main] o.s.core.log.logger.BladeLogger          : blade-iot: BladeLogger init success!
2025-03-06 22:34:37.685  INFO 35491 --- [           main] o.s.b.a.e.web.EndpointLinksResolver      : Exposing 1 endpoint(s) beneath base path '/actuator'
2025-03-06 22:34:37.798  INFO 35491 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create database sql:CREATE DATABASE IF NOT EXISTS links PRECISION 'ms' CACHEMODEL 'both' KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1

2025-03-06 22:34:37.940  INFO 35491 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_logger (`time` timestamp, `topic` NCHAR(128), `message` NCHAR(8192)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:38.157  INFO 35491 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-2} inited
2025-03-06 22:34:38.165  INFO 35491 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_event (`time` timestamp, `eventName` NCHAR(32), `identifier` NCHAR(32), `eventType` NCHAR(12), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:38.166  INFO 35491 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_command (`time` timestamp, `commandName` NCHAR(32), `identifier` NCHAR(32), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:38.187  INFO 35491 --- [           main] io.undertow                              : starting server: Undertow - 2.3.17.Final
2025-03-06 22:34:38.204  INFO 35491 --- [           main] org.xnio                                 : XNIO version 3.8.16.Final
2025-03-06 22:34:38.221  INFO 35491 --- [           main] org.xnio.nio                             : XNIO NIO Implementation Version 3.8.16.Final
2025-03-06 22:34:38.265  INFO 35491 --- [           main] org.jboss.threads                        : JBoss Threads version 3.5.0.Final
2025-03-06 22:34:38.299  INFO 35491 --- [           main] o.s.b.w.e.undertow.UndertowWebServer     : Undertow started on port 80 (http)
2025-03-06 22:34:38.304  INFO 35491 --- [sync-executor-1] o.s.core.launch.StartEventListener       : ---[BLADE-IOT]---启动完成，当前使用的端口:[80]，环境变量:[dev]---
2025-03-06 22:34:38.583  INFO 35491 --- [           main] org.springblade.ServerApplication        : Started ServerApplication in 7.283 seconds (process running for 7.921)
2025-03-06 22:34:38.732  INFO 35491 --- [-192.168.31.254] io.undertow.servlet                      : Initializing Spring DispatcherServlet 'dispatcherServlet'
2025-03-06 22:34:38.732  INFO 35491 --- [-192.168.31.254] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2025-03-06 22:34:38.733  INFO 35491 --- [-192.168.31.254] o.s.web.servlet.DispatcherServlet        : Completed initialization in 1 ms

三、启动消息服务 kafka

本地开发为迅速跑通集群模式，可直接docker快速启动命令如下

docker run -d \
  --name kafka \
  -p 9092:9092 \
  -e KAFKA_CFG_NODE_ID=1 \
  -e KAFKA_CFG_PROCESS_ROLES=controller,broker \
  -e KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093 \
  -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \
  -e KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT \
  -e KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@localhost:9093 \
  -e KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \
  -e ALLOW_PLAINTEXT_LISTENER=yes \
  -v /docker/data/kafka:/data \
  bitnami/kafka:3.9.0

若使用部署包安装需先通过官网下载：点击下载
解压后进入对应目录执行如下操作

1). 生成集群ID

bin/kafka-storage.sh random-uuid

2). 生成配置

bin/kafka-storage.sh format -t ${集群ID} -c config/kraft/server.properties

3). 启动

bin/kafka-server-start.sh config/kraft/server.properties

4). 配置 linux 服务 vim /etc/systemd/system/kafka.service 注意：更改 kafka 目录和 jvm 内存配置。

[Unit]
Description=Apache Kafka server (broker)
Documentation=http://kafka.apache.org/documentation.html
Requires=network.target
After=network.target kafka-zookeeper.service

[Service]
Type=simple
Environment="KAFKA_HEAP_OPTS=-Xmx6G -Xms6G"
WorkingDirectory=/data/soft/kafka
ExecStart=/bin/bash /data/soft/kafka/bin/kafka-server-start.sh /data/soft/kafka/config/kraft/server.properties
ExecStop=/bin/bash /data/soft/kafka/bin/kafka-server-stop.sh
Restart=on-failure

[Install]
WantedBy=multi-user.target

## 开机启动
systemctl enable kafka.service
## 启动
systemctl start kafka.service
## 停止
systemctl stop kafka.service
## 重启
systemctl restart kafka.service

kafka 桌面端: 下载地址

四、启动MQTT服务 blade-broker

修改blade-broker的pom.xml文件，将依赖修改为集群版本并且刷新工程重新加载maven依赖

 <dependencies>

     <!-- broker 单机 -->
     <!--<dependency>
         <groupId>org.springblade</groupId>
         <artifactId>blade-broker-local</artifactId>
     </dependency>-->

     <!-- broker 集群 使用 kafka -->
     <dependency>
         <groupId>org.springblade</groupId>
         <artifactId>blade-broker-cluster</artifactId>
     </dependency>
     <dependency>
         <groupId>org.springblade</groupId>
         <artifactId>blade-mq-kafka</artifactId>
     </dependency>

 </dependencies>

前往BladeX-Links工程下的blade-broker模块的application.yml配置文件，修改密钥保持与blade-server一致
- 具体路径如下：BladeX-Links/blade-service/blade-broker/src/main/resources/application.yml
- 需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的签名)：
```
#blade配置
blade:
  token:
    #使用 @org.springblade.test.SignKeyGenerator 获取
    #需要将blade-server与blade-broker服务对应的sign-key配置保持一致
    sign-key: 6klRvnw*************0TB4m51ZSh
```
前往BladeX-Links工程下的blade-broker模块的application-dev.yml配置文件，修改kafka配置，若集群有多个节点则以逗号分隔
```
#kafka配置
spring:
  kafka:
    bootstrap-servers: 127.0.0.1:9092
```

前往BladeX-Links工程下的blade-broker模块的application-dev.yml配置文件，修改mqtt、database、redis、influxdb、minio等配置

具体路径如下：BladeX-Links/blade-service/blade-broker/src/main/resources/application-dev.yml
需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的ip、端口、用户名、密码等配置)：

#数据源配置
spring:
  data:
    redis:
      ##redis 单机环境配置
      host: 127.0.0.1
      port: 6379
      password:
      database: 0
      ssl:
        enabled: false
      ##redis 集群环境配置
      #cluster:
      #  nodes: 127.0.0.1:7001,127.0.0.1:7002,127.0.0.1:7003
      #  commandTimeout: 5000
  datasource:
    url: jdbc:mysql://localhost:3306/bladex_iot?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver
  kafka:
    bootstrap-servers: 127.0.0.1:9092

#时序数据库配置
tdengine:
  enabled: true     # 是否开启，多个时序库插件依赖同时导入可采用此参数配置，开启的时序库
  username: root
  password: taosdata
  database: links   # 库名，会自动建库
  jdbc-url: jdbc:TAOS-RS://127.0.0.1:6041?useSSL=false
  # 数据精度，默认：毫秒
  precision: ms
  # 数据保存的天数，默认：10年
  keep: 3650
  # 批量写入相关配置
  enable-batch: true # 开启批量写，默认：开
  batch-size: 1000   # 批次大小，默认：1000
  flush-duration: 1s # 批次写入时间，默认：1s 写入一次
  # 连接池相关配置，可按需求进行配置，建议改大一些
  initial-size: 8    # 初始化的连接数，默认：8
  max-active: 32     # 最大活跃连接数，默认：32
  min-idle: 8        # 最小活跃连接数，默认：8
  max-wait: -1       # 最大等待时间，默认：-1 不限制

#mqtt配置
mqtt:
  server:
    enabled: true               # 是否开启服务端，默认：true
    port: 1883                  # 端口，默认：1883
    name: BladeX-Mqtt-Server    # 名称，默认：Mica-Mqtt-Server
    heartbeat-timeout: 120000   # 心跳超时，单位毫秒，默认: 1000 * 120
    read-buffer-size: 8KB       # 接收数据的 buffer size，默认：8k
    max-bytes-in-message: 10MB  # 消息解析最大 bytes 长度，默认：10M
    debug: true                 # 如果开启 prometheus 指标收集建议关闭
    stat-enable: true           # 开启指标收集，debug 和 prometheus 开启时需要打开，默认开启，关闭节省内存
    web-port: 8083              # http、websocket 端口，默认：8083
    websocket-enable: true      # 是否开启 websocket，默认： true
    http-enable: false          # 是否开启 http api，默认： false
    ssl: # mqtt tcp ssl 认证
      enabled: false            # 是否开启 ssl 认证，2.1.0 开始支持双向认证
      keystore-path:            # 必须参数：ssl keystore 目录，支持 classpath:/ 路径。
      keystore-pass:            # 必选参数：ssl keystore 密码
      truststore-path:          # 可选参数：ssl 双向认证 truststore 目录，支持 classpath:/ 路径。
      truststore-pass:          # 可选参数：ssl 双向认证 truststore 密码
      client-auth: none         # 是否需要客户端认证（双向认证），默认：NONE（不需要）

#blade配置
blade:
  iot:
    # 外网ip或者域名
    mqtt-ip: 127.0.0.1
    # 外网可用的端口
    mqtt-port: 1883

启动BladeX-Links工程下的blade-broker模块的BrokerApplication启动类，看到如下日志，则说明启动成功

/Library/Java/JavaVirtualMachines/zulu-17.jdk/Contents/Home/bin/java -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:63100,suspend=y,server=n --add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.lang.reflect=ALL-UNNAMED -agentpath:/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/idea_libasyncProfiler_dylib_temp_folder/libasyncProfiler.dylib=version,jfr,event=wall,interval=10ms,cstack=no,file=/Users/chill/IdeaSnapshots/BrokerApplication_2025_03_06_223621.jfr,log=/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/BrokerApplication_2025_03_06_223621.jfr.log.txt,logLevel=DEBUG -XX:TieredStopAtLevel=1 -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -Dmanagement.endpoints.jmx.exposure.include=* -javaagent:/Users/chill/Library/Caches/JetBrains/IntelliJIdea2024.3/captureAgent/debugger-agent.jar -Dkotlinx.coroutines.debug.enable.creation.stack.trace=false -Ddebugger.agent.enable.coroutines=true -Dkotlinx.coroutines.debug.enable.flows.stack.trace=true -Dkotlinx.coroutines.debug.enable.mutable.state.flows.stack.trace=true -Dfile.encoding=UTF-8 -classpath /Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-broker/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-broker-cluster/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-broker-core/target/classes:/Users/chill/.m2/repository/org/openjdk/nashorn/nashorn-core/15.6/nashorn-core-15.6.jar:/Users/chill/.m2/repository/org/ow2/asm/asm/7.3.1/asm-7.3.1.jar:/Users/chill/.m2/repository/org/ow2/asm/asm-commons/7.3.1/asm-commons-7.3.1.jar:/Users/chill/.m2/repository/org/ow2/asm/asm-analysis/7.3.1/asm-analysis-7.3.1.jar:/Users/chill/.m2/repository/org/ow2/asm/asm-tree/7.3.1/asm-tree-7.3.1.jar:/Users/chill/.m2/repository/org/ow2/asm/asm-util/7.3.1/asm-util-7.3.1.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-mq-api/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-api/target/classes:/Users/chill/.m2/repository/com/github/ben-manes/caffeine/caffeine/3.1.8/caffeine-3.1.8.jar:/Users/chill/.m2/repository/org/checkerframework/checker-qual/3.37.0/checker-qual-3.37.0.jar:/Users/chill/.m2/repository/com/google/errorprone/error_prone_annotations/2.21.1/error_prone_annotations-2.21.1.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-mq-kafka/target/classes:/Users/chill/.m2/repository/org/springblade/blade-core-tool/4.5.0/blade-core-tool-4.5.0.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.15.4/jackson-datatype-jsr310-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.15.4/jackson-annotations-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.15.4/jackson-core-2.15.4.jar:/Users/chill/.m2/repository/com/google/guava/guava/33.1.0-jre/guava-33.1.0-jre.jar:/Users/chill/.m2/repository/com/google/guava/failureaccess/1.0.2/failureaccess-1.0.2.jar:/Users/chill/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/chill/.m2/repository/com/google/j2objc/j2objc-annotations/3.0.0/j2objc-annotations-3.0.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-annotations-jakarta/2.2.19/swagger-annotations-jakarta-2.2.19.jar:/Users/chill/.m2/repository/org/bouncycastle/bcprov-jdk18on/1.78.1/bcprov-jdk18on-1.78.1.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-core/target/classes:/Users/chill/.m2/repository/org/springframework/kafka/spring-kafka/3.1.10/spring-kafka-3.1.10.jar:/Users/chill/.m2/repository/org/springframework/spring-context/6.1.15/spring-context-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-beans/6.1.15/spring-beans-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-expression/6.1.15/spring-expression-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-messaging/6.1.15/spring-messaging-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-tx/6.1.15/spring-tx-6.1.15.jar:/Users/chill/.m2/repository/org/apache/kafka/kafka-clients/3.6.2/kafka-clients-3.6.2.jar:/Users/chill/.m2/repository/com/github/luben/zstd-jni/1.5.5-1/zstd-jni-1.5.5-1.jar:/Users/chill/.m2/repository/org/lz4/lz4-java/1.8.0/lz4-java-1.8.0.jar:/Users/chill/.m2/repository/org/xerial/snappy/snappy-java/1.1.10.5/snappy-java-1.1.10.5.jar:/Users/chill/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-base/target/classes:/Users/chill/.m2/repository/org/springblade/blade-core-launch/4.5.0/blade-core-launch-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-web/3.2.12/spring-boot-starter-web-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-json/3.2.12/spring-boot-starter-json-3.2.12.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jdk8/2.15.4/jackson-datatype-jdk8-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/module/jackson-module-parameter-names/2.15.4/jackson-module-parameter-names-2.15.4.jar:/Users/chill/.m2/repository/org/springframework/spring-web/6.1.15/spring-web-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-webmvc/6.1.15/spring-webmvc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-undertow/3.2.12/spring-boot-starter-undertow-3.2.12.jar:/Users/chill/.m2/repository/io/undertow/undertow-core/2.3.17.Final/undertow-core-2.3.17.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-api/3.8.16.Final/xnio-api-3.8.16.Final.jar:/Users/chill/.m2/repository/org/wildfly/common/wildfly-common/1.5.4.Final/wildfly-common-1.5.4.Final.jar:/Users/chill/.m2/repository/org/wildfly/client/wildfly-client-config/1.0.1.Final/wildfly-client-config-1.0.1.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-nio/3.8.16.Final/xnio-nio-3.8.16.Final.jar:/Users/chill/.m2/repository/org/jboss/threads/jboss-threads/3.5.0.Final/jboss-threads-3.5.0.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-servlet/2.3.17.Final/undertow-servlet-2.3.17.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-websockets-jsr/2.3.17.Final/undertow-websockets-jsr-2.3.17.Final.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-api/2.1.1/jakarta.websocket-api-2.1.1.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-client-api/2.1.1/jakarta.websocket-client-api-2.1.1.jar:/Users/chill/.m2/repository/org/apache/tomcat/embed/tomcat-embed-el/10.1.33/tomcat-embed-el-10.1.33.jar:/Users/chill/.m2/repository/jakarta/servlet/jakarta.servlet-api/6.0.0/jakarta.servlet-api-6.0.0.jar:/Users/chill/.m2/repository/javax/xml/bind/jaxb-api/2.3.1/jaxb-api-2.3.1.jar:/Users/chill/.m2/repository/javax/activation/javax.activation-api/1.2.0/javax.activation-api-1.2.0.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-core/4.0.5/jaxb-core-4.0.5.jar:/Users/chill/.m2/repository/org/eclipse/angus/angus-activation/2.0.2/angus-activation-2.0.2.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-impl/4.0.5/jaxb-impl-4.0.5.jar:/Users/chill/.m2/repository/javax/activation/activation/1.1.1/activation-1.1.1.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-mybatis/4.5.0/blade-starter-mybatis-4.5.0.jar:/Users/chill/.m2/repository/org/mybatis/mybatis/3.5.16/mybatis-3.5.16.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-spring/3.0.4/mybatis-spring-3.0.4.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus/3.5.8/mybatis-plus-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-core/3.5.8/mybatis-plus-core-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-annotation/3.5.8/mybatis-plus-annotation-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-extension/3.5.8/mybatis-plus-extension-3.5.8.jar:/Users/chill/.m2/repository/com/github/jsqlparser/jsqlparser/5.0/jsqlparser-5.0.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot-autoconfigure/3.5.8/mybatis-plus-spring-boot-autoconfigure-3.5.8.jar:/Users/chill/.m2/repository/org/springblade/blade-core-boot/4.5.0/blade-core-boot-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-jdbc/3.2.12/spring-boot-starter-jdbc-3.2.12.jar:/Users/chill/.m2/repository/com/zaxxer/HikariCP/5.0.1/HikariCP-5.0.1.jar:/Users/chill/.m2/repository/org/springframework/spring-jdbc/6.1.15/spring-jdbc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-cache/3.2.12/spring-boot-starter-cache-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-context-support/6.1.15/spring-context-support-6.1.15.jar:/Users/chill/.m2/repository/org/springblade/blade-core-secure/4.5.0/blade-core-secure-4.5.0.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-impl/0.11.2/jjwt-impl-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-api/0.11.2/jjwt-api-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-jackson/0.11.2/jjwt-jackson-0.11.2.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-cache/4.5.0/blade-starter-cache-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-log/4.5.0/blade-starter-log-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-swagger/4.5.0/blade-starter-swagger-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-jakarta-spring-boot-starter/4.5.0/knife4j-openapi3-jakarta-spring-boot-starter-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-core/4.5.0/knife4j-core-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-ui/4.5.0/knife4j-openapi3-ui-4.5.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-ui/2.3.0/springdoc-openapi-starter-webmvc-ui-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-api/2.3.0/springdoc-openapi-starter-webmvc-api-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-common/2.3.0/springdoc-openapi-starter-common-2.3.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-core-jakarta/2.2.19/swagger-core-jakarta-2.2.19.jar:/Users/chill/.m2/repository/org/apache/commons/commons-lang3/3.13.0/commons-lang3-3.13.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-models-jakarta/2.2.19/swagger-models-jakarta-2.2.19.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.15.4/jackson-dataformat-yaml-2.15.4.jar:/Users/chill/.m2/repository/org/webjars/swagger-ui/5.10.3/swagger-ui-5.10.3.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot3-starter/3.5.8/mybatis-plus-spring-boot3-starter-3.5.8.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/3.2.12/spring-boot-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-typehandlers-jsr310/1.0.2/mybatis-typehandlers-jsr310-1.0.2.jar:/Users/chill/.m2/repository/net/sf/ehcache/ehcache/2.10.5/ehcache-2.10.5.jar:/Users/chill/.m2/repository/com/alibaba/druid-spring-boot-3-starter/1.2.23/druid-spring-boot-3-starter-1.2.23.jar:/Users/chill/.m2/repository/com/mysql/mysql-connector-j/8.3.0/mysql-connector-j-8.3.0.jar:/Users/chill/.m2/repository/com/google/protobuf/protobuf-java/3.25.1/protobuf-java-3.25.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-aop/3.2.12/spring-boot-starter-aop-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-aop/6.1.15/spring-aop-6.1.15.jar:/Users/chill/.m2/repository/org/aspectj/aspectjweaver/1.9.22.1/aspectjweaver-1.9.22.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-actuator/3.2.12/spring-boot-starter-actuator-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator-autoconfigure/3.2.12/spring-boot-actuator-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator/3.2.12/spring-boot-actuator-3.2.12.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-observation/1.12.13/micrometer-observation-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-commons/1.12.13/micrometer-commons-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-jakarta9/1.12.13/micrometer-jakarta9-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-core/1.12.13/micrometer-core-1.12.13.jar:/Users/chill/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.12/HdrHistogram-2.1.12.jar:/Users/chill/.m2/repository/org/latencyutils/LatencyUtils/2.0.3/LatencyUtils-2.0.3.jar:/Users/chill/.m2/repository/org/springframework/retry/spring-retry/2.0.10/spring-retry-2.0.10.jar:/Users/chill/.m2/repository/org/hibernate/validator/hibernate-validator/8.0.1.Final/hibernate-validator-8.0.1.Final.jar:/Users/chill/.m2/repository/jakarta/validation/jakarta.validation-api/3.0.2/jakarta.validation-api-3.0.2.jar:/Users/chill/.m2/repository/org/jboss/logging/jboss-logging/3.5.3.Final/jboss-logging-3.5.3.Final.jar:/Users/chill/.m2/repository/com/fasterxml/classmate/1.6.0/classmate-1.6.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-tenant/4.5.0/blade-starter-tenant-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-redis/4.5.0/blade-starter-redis-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-data-redis/3.2.12/spring-boot-starter-data-redis-3.2.12.jar:/Users/chill/.m2/repository/io/lettuce/lettuce-core/6.3.2.RELEASE/lettuce-core-6.3.2.RELEASE.jar:/Users/chill/.m2/repository/io/netty/netty-common/4.1.115.Final/netty-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-handler/4.1.115.Final/netty-handler-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-resolver/4.1.115.Final/netty-resolver-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-buffer/4.1.115.Final/netty-buffer-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.115.Final/netty-transport-native-unix-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-codec/4.1.115.Final/netty-codec-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport/4.1.115.Final/netty-transport-4.1.115.Final.jar:/Users/chill/.m2/repository/io/projectreactor/reactor-core/3.6.12/reactor-core-3.6.12.jar:/Users/chill/.m2/repository/org/reactivestreams/reactive-streams/1.0.4/reactive-streams-1.0.4.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-redis/3.2.12/spring-data-redis-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-keyvalue/3.2.12/spring-data-keyvalue-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-commons/3.2.12/spring-data-commons-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-oxm/6.1.15/spring-oxm-6.1.15.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-core/1.6.0/protostuff-core-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-api/1.6.0/protostuff-api-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-runtime/1.6.0/protostuff-runtime-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-collectionschema/1.6.0/protostuff-collectionschema-1.6.0.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-server-spring-boot-starter/3.1.11/mica-mqttx-server-spring-boot-starter-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-server/3.1.11/mica-mqttx-server-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-core/1.0.13/mica-net-core-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-utils/1.0.13/mica-net-utils-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-http/1.0.13/mica-net-http-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-client/3.1.11/mica-mqttx-client-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-common/3.1.11/mica-mqttx-common-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-codec/3.1.11/mica-mqttx-codec-3.1.11.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-tdengine/target/classes:/Users/chill/.m2/repository/com/taosdata/jdbc/taos-jdbcdriver/3.5.1/taos-jdbcdriver-3.5.1.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpclient/4.5.14/httpclient-4.5.14.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpcore/4.4.16/httpcore-4.4.16.jar:/Users/chill/.m2/repository/commons-codec/commons-codec/1.16.1/commons-codec-1.16.1.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.15.4/jackson-databind-2.15.4.jar:/Users/chill/.m2/repository/org/java-websocket/Java-WebSocket/1.5.4/Java-WebSocket-1.5.4.jar:/Users/chill/.m2/repository/com/alibaba/druid/1.2.23/druid-1.2.23.jar:/Users/chill/.m2/repository/com/rabbitmq/amqp-client/5.21.0/amqp-client-5.21.0.jar:/Users/chill/.m2/repository/org/slf4j/slf4j-api/2.0.16/slf4j-api-2.0.16.jar:/Users/chill/.m2/repository/com/ibeetl/beetl/3.18.0.RELEASE/beetl-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/org/antlr/antlr4-runtime/4.9.2/antlr4-runtime-4.9.2.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-core/3.18.0.RELEASE/beetl-core-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-default-antlr4.9-support/3.18.0.RELEASE/beetl-default-antlr4.9-support-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/com/ibeetl/beetl-ext/3.18.0.RELEASE/beetl-ext-3.18.0.RELEASE.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter/3.2.12/spring-boot-starter-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot/3.2.12/spring-boot-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-logging/3.2.12/spring-boot-starter-logging-3.2.12.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-classic/1.4.14/logback-classic-1.4.14.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-core/1.4.14/logback-core-1.4.14.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-to-slf4j/2.21.1/log4j-to-slf4j-2.21.1.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-api/2.21.1/log4j-api-2.21.1.jar:/Users/chill/.m2/repository/org/slf4j/jul-to-slf4j/2.0.16/jul-to-slf4j-2.0.16.jar:/Users/chill/.m2/repository/jakarta/annotation/jakarta.annotation-api/2.1.1/jakarta.annotation-api-2.1.1.jar:/Users/chill/.m2/repository/org/yaml/snakeyaml/2.2/snakeyaml-2.2.jar:/Users/chill/.m2/repository/jakarta/xml/bind/jakarta.xml.bind-api/4.0.2/jakarta.xml.bind-api-4.0.2.jar:/Users/chill/.m2/repository/jakarta/activation/jakarta.activation-api/2.1.3/jakarta.activation-api-2.1.3.jar:/Users/chill/.m2/repository/org/springframework/spring-core/6.1.15/spring-core-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-jcl/6.1.15/spring-jcl-6.1.15.jar:/Users/chill/.m2/repository/com/squareup/okhttp3/okhttp/4.12.0/okhttp-4.12.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio/3.6.0/okio-3.6.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio-jvm/3.6.0/okio-jvm-3.6.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-common/1.9.25/kotlin-stdlib-common-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk8/1.9.25/kotlin-stdlib-jdk8-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib/1.9.25/kotlin-stdlib-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/annotations/13.0/annotations-13.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk7/1.9.25/kotlin-stdlib-jdk7-1.9.25.jar:/Users/chill/.m2/repository/net/dreamlu/mica-auto/3.1.4/mica-auto-3.1.4.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-configuration-processor/3.2.12/spring-boot-configuration-processor-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-autoconfigure-processor/3.2.12/spring-boot-autoconfigure-processor-3.2.12.jar:/Users/chill/.m2/repository/org/projectlombok/lombok/1.18.36/lombok-1.18.36.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar org.springblade.mqtt.broker.BrokerApplication
Connected to the target VM, address: '127.0.0.1:63100', transport: 'socket'
----启动中，读取到的环境变量:[dev]，jar地址:[/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-broker/target/classes/]----
2025-03-06 22:36:23.462  INFO 35710 --- [kground-preinit] o.h.validator.internal.util.Version      : HV000001: Hibernate Validator 8.0.1.Final
  ____  _           _     __   __    _     _       _
|  _ \| |         | |    \ \ / /   | |   (_)     | |
| |_) | | __ _  __| | ___ \ V /    | |    _ _ __ | | _____
|  _ <| |/ _` |/ _` |/ _ \ > <     | |   | | '_ \| |/ / __|
| |_) | | (_| | (_| |  __// . \    | |___| | | | |   <\__ \
|____/|_|\__,_|\__,_|\___/_/ \_\   |_____|_|_| |_|_|\_\___/

:: BladeX :: blade-broker:dev :: Running SpringBoot 3.2.12 ::

2025-03-06 22:36:23.488  INFO 35710 --- [           main] o.s.mqtt.broker.BrokerApplication        : Starting BrokerApplication using Java 17.0.10 with PID 35710 (/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-broker/target/classes started by chill in /Users/chill/Workspaces/product/BladeX-Links)
2025-03-06 22:36:23.488 DEBUG 35710 --- [           main] o.s.mqtt.broker.BrokerApplication        : Running with Spring Boot v3.2.12, Spring v6.1.15
2025-03-06 22:36:23.488  INFO 35710 --- [           main] o.s.mqtt.broker.BrokerApplication        : The following 1 profile is active: "dev"
2025-03-06 22:36:24.068  INFO 35710 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
2025-03-06 22:36:24.070  INFO 35710 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2025-03-06 22:36:24.079  INFO 35710 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 3 ms. Found 0 Redis repository interfaces.
2025-03-06 22:36:24.127  WARN 35710 --- [           main] o.m.s.mapper.ClassPathMapperScanner      : No MyBatis mapper was found in '[org.springblade.mqtt.broker]' package. Please check your configuration.
2025-03-06 22:36:24.192  INFO 35710 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor init.
2025-03-06 22:36:24.214  INFO 35710 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor process @BladePropertySource bean.
2025-03-06 22:36:24.387  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'mqttFunctionManager' of type [net.dreamlu.iot.mqtt.core.server.func.MqttFunctionManager] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [mqttServerFunctionDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.392  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springblade.core.redis.config.RedisPubSubConfiguration' of type [org.springblade.core.redis.config.RedisPubSubConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). The currently created BeanPostProcessor [topicListenerDetector] is declared through a non-static factory method on that class; consider declaring it as static instead.
2025-03-06 22:36:24.400  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.data.redis-org.springframework.boot.autoconfigure.data.redis.RedisProperties' of type [org.springframework.boot.autoconfigure.data.redis.RedisProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.403  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration' of type [org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.405  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisConnectionDetails' of type [org.springframework.boot.autoconfigure.data.redis.PropertiesRedisConnectionDetails] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.408  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.ssl-org.springframework.boot.autoconfigure.ssl.SslProperties' of type [org.springframework.boot.autoconfigure.ssl.SslProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.409  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.ssl.SslAutoConfiguration' of type [org.springframework.boot.autoconfigure.ssl.SslAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.411  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'fileWatcher' of type [org.springframework.boot.autoconfigure.ssl.FileWatcher] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.412  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'sslPropertiesSslBundleRegistrar' of type [org.springframework.boot.autoconfigure.ssl.SslPropertiesBundleRegistrar] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.415  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'sslBundleRegistry' of type [org.springframework.boot.ssl.DefaultSslBundleRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.416  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration' of type [org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.428  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.429  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.430  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'management.simple.metrics.export-org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleProperties' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.432  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'simpleConfig' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimplePropertiesConfigAdapter] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.434  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.436  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'micrometerClock' of type [io.micrometer.core.instrument.Clock$1] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.447  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'simpleMeterRegistry' of type [io.micrometer.core.instrument.simple.SimpleMeterRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.455  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'micrometerOptions' of type [io.lettuce.core.metrics.MicrometerOptions] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.456  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'lettuceMetrics' of type [org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration$$Lambda$784/0x00000070015cc800] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.495  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'lettuceClientResources' of type [io.lettuce.core.resource.DefaultClientResources] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.535  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisConnectionFactory' of type [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.548  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisMessageListenerContainer' of type [org.springframework.data.redis.listener.RedisMessageListenerContainer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.554  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springblade.core.redis.config.ProtoStuffSerializerConfiguration' of type [org.springblade.core.redis.config.ProtoStuffSerializerConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.575  WARN 35710 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisSerializer' of type [org.springblade.core.redis.serializer.ProtoStuffSerializer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:36:24.727  WARN 35710 --- [           main] io.undertow.websockets.jsr               : UT026010: Buffer pool was not set on WebSocketDeploymentInfo, the default pool will be used
2025-03-06 22:36:24.737  INFO 35710 --- [           main] io.undertow.servlet                      : Initializing Spring embedded WebApplicationContext
2025-03-06 22:36:24.737  INFO 35710 --- [           main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1231 ms
2025-03-06 22:36:24.874  INFO 35710 --- [           main] c.a.d.s.b.a.DruidDataSourceAutoConfigure : Init DruidDataSource
2025-03-06 22:36:25.002  INFO 35710 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-1} inited
2025-03-06 22:36:25.890  INFO 35710 --- [           main] o.s.c.redis.pubsub.RedisPubSubPublisher  : RPubSubPublisher init success.
2025-03-06 22:36:25.934  INFO 35710 --- [           main] o.s.c.r.pubsub.RPubSubListenerDetector   : Found @RPubSubListener on bean:org.springblade.iot.broker.core.service.impl.ProtocolMapperServiceImpl method:public void org.springblade.iot.broker.core.service.impl.ProtocolMapperServiceImpl.subReloadEvent(org.springblade.core.redis.pubsub.RPubSubEvent)
2025-03-06 22:36:26.016  INFO 35710 --- [           main] n.d.i.m.core.server.MqttServerCreator    : Mica mqtt http api enable:false websocket enable:true
2025-03-06 22:36:26.038  INFO 35710 --- [           main] o.s.core.boot.config.RetryConfiguration  : configServerRetryInterceptor: Changing backOffOptions to initial: 1000, multiplier: 1.2, maxInterval: 5000
2025-03-06 22:36:26.053  INFO 35710 --- [           main] o.s.core.log.logger.BladeLogger          : blade-broker: BladeLogger init success!
2025-03-06 22:36:26.133  INFO 35710 --- [           main] o.s.c.r.pubsub.RPubSubListenerDetector   : Found @RPubSubListener on bean:org.springblade.iot.broker.core.service.impl.ProductScriptServiceImpl method:public void org.springblade.iot.broker.core.service.impl.ProductScriptServiceImpl.subReloadEvent(org.springblade.core.redis.pubsub.RPubSubEvent)
2025-03-06 22:36:26.221  INFO 35710 --- [           main] o.s.c.r.pubsub.RPubSubListenerDetector   : Found @RPubSubListener on bean:org.springblade.iot.tsdb.config.IotTslCacheConfiguration$CacheUpdateListener method:public void org.springblade.iot.tsdb.config.IotTslCacheConfiguration$CacheUpdateListener.tslUpdateEvent(org.springblade.core.redis.pubsub.RPubSubEvent)
2025-03-06 22:36:26.653  INFO 35710 --- [           main] o.s.b.a.e.web.EndpointLinksResolver      : Exposing 1 endpoint(s) beneath base path '/actuator'
2025-03-06 22:36:26.748 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : original SQL: SELECT  id,product_id,product_key,script,script_type,tenant_id,create_user,create_dept,create_time,update_user,update_time,status,is_deleted  FROM iot_product_script  WHERE is_deleted=0     AND (status = ?)
2025-03-06 22:36:26.778 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : SQL to parse, SQL: SELECT  id,product_id,product_key,script,script_type,tenant_id,create_user,create_dept,create_time,update_user,update_time,status,is_deleted  FROM iot_product_script  WHERE is_deleted=0     AND (status = ?)
2025-03-06 22:36:26.784 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : parse the finished SQL: SELECT id, product_id, product_key, script, script_type, tenant_id, create_user, create_dept, create_time, update_user, update_time, status, is_deleted FROM iot_product_script WHERE is_deleted = 0 AND (status = ?)
2025-03-06 22:36:26.979  INFO 35710 --- [           main] o.s.core.mp.plugins.SqlLogInterceptor    :

=================== Sql Logger ===================
select id, product_id, product_key, script, script_type , tenant_id, create_user, create_dept, create_time, update_user , update_time, status, is_deleted from iot_product_script where is_deleted = 0 and (status = 1)
============ Sql Execute Time: 1.156ms ===========

2025-03-06 22:36:26.988 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : original SQL: SELECT  id,protocol_id,data_type,flow,in_topic_reg,in_topic_example,in_body_example,out_topic_template,out_body_template,create_user,create_dept,create_time,update_user,update_time,status,is_deleted  FROM iot_protocol_mapper  WHERE is_deleted=0
2025-03-06 22:36:26.991 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : SQL to parse, SQL: SELECT  id,protocol_id,data_type,flow,in_topic_reg,in_topic_example,in_body_example,out_topic_template,out_body_template,create_user,create_dept,create_time,update_user,update_time,status,is_deleted  FROM iot_protocol_mapper  WHERE is_deleted=0
2025-03-06 22:36:26.991 DEBUG 35710 --- [           main] o.s.core.tenant.BladeTenantInterceptor   : parse the finished SQL: SELECT id, protocol_id, data_type, flow, in_topic_reg, in_topic_example, in_body_example, out_topic_template, out_body_template, create_user, create_dept, create_time, update_user, update_time, status, is_deleted FROM iot_protocol_mapper WHERE is_deleted = 0
2025-03-06 22:36:26.995  INFO 35710 --- [           main] o.s.core.mp.plugins.SqlLogInterceptor    :

=================== Sql Logger ===================
select id, protocol_id, data_type, flow, in_topic_reg , in_topic_example, in_body_example, out_topic_template, out_body_template, create_user , create_dept, create_time, update_user, update_time, status , is_deleted from iot_protocol_mapper where is_deleted = 0
============ Sql Execute Time: 1.873ms ===========

2025-03-06 22:36:27.010  INFO 35710 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create database sql:CREATE DATABASE IF NOT EXISTS links PRECISION 'ms' CACHEMODEL 'both' KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1

2025-03-06 22:36:27.126  INFO 35710 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_logger (`time` timestamp, `topic` NCHAR(128), `message` NCHAR(8192)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:36:27.156  INFO 35710 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-2} inited
2025-03-06 22:36:27.158  INFO 35710 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_event (`time` timestamp, `eventName` NCHAR(32), `identifier` NCHAR(32), `eventType` NCHAR(12), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:36:27.159  INFO 35710 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_command (`time` timestamp, `commandName` NCHAR(32), `identifier` NCHAR(32), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:36:27.206  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:36:27.206  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:36:27.206  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271787206
2025-03-06 22:36:27.337  INFO 35710 --- [| adminclient-1] o.a.kafka.common.utils.AppInfoParser     : App info kafka.admin.client for adminclient-1 unregistered
2025-03-06 22:36:27.339  INFO 35710 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Metrics scheduler closed
2025-03-06 22:36:27.339  INFO 35710 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2025-03-06 22:36:27.339  INFO 35710 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Metrics reporters closed
2025-03-06 22:36:27.346  INFO 35710 --- [           main] io.undertow                              : starting server: Undertow - 2.3.17.Final
2025-03-06 22:36:27.350  INFO 35710 --- [           main] org.xnio                                 : XNIO version 3.8.16.Final
2025-03-06 22:36:27.354  INFO 35710 --- [           main] org.xnio.nio                             : XNIO NIO Implementation Version 3.8.16.Final
2025-03-06 22:36:27.364  INFO 35710 --- [           main] org.jboss.threads                        : JBoss Threads version 3.5.0.Final
2025-03-06 22:36:27.381  INFO 35710 --- [           main] o.s.b.w.e.undertow.UndertowWebServer     : Undertow started on port 8888 (http)
2025-03-06 22:36:27.382  INFO 35710 --- [sync-executor-1] o.s.core.launch.StartEventListener       : ---[BLADE-BROKER]---启动完成，当前使用的端口:[8888]，环境变量:[dev]---
2025-03-06 22:36:27.408  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:36:27.408  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:36:27.408  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271787408
2025-03-06 22:36:27.412  INFO 35710 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Subscribed to topic(s): blade_links_acl_clean
2025-03-06 22:36:27.417  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:36:27.417  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:36:27.417  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271787417
2025-03-06 22:36:27.419  INFO 35710 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Subscribed to topic(s): blade_links_kick_out
2025-03-06 22:36:27.421  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:36:27.421  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:36:27.421  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271787421
2025-03-06 22:36:27.422  INFO 35710 --- [ntainer#2-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:36:27.422  INFO 35710 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:36:27.422  INFO 35710 --- [ntainer#3-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:36:27.422  INFO 35710 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Subscribed to topic(s): blade_links_msg_down
2025-03-06 22:36:27.423  INFO 35710 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:36:27.423  INFO 35710 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.423  INFO 35710 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.426  INFO 35710 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:36:27.426  INFO 35710 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.427  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:36:27.427  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:36:27.427  INFO 35710 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271787427
2025-03-06 22:36:27.428  INFO 35710 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Subscribed to topic(s): blade_cluster_exchange
2025-03-06 22:36:27.429  INFO 35710 --- [       Thread-1] org.tio.utils.timer.TimingWheelThread    : Starting
2025-03-06 22:36:27.429  INFO 35710 --- [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:36:27.430  INFO 35710 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:36:27.430  INFO 35710 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.431  INFO 35710 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: need to re-join with the given member-id: consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3-8493c850-9dff-472a-aad7-faee70e6158f
2025-03-06 22:36:27.431  INFO 35710 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-3, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: need to re-join with the given member-id: consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1-b771c30a-f6e4-4470-8847-556d18219451
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-1, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: need to re-join with the given member-id: consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2-74103635-187e-411c-b6b8-0a9c78315f3d
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-2, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.432  INFO 35710 --- [           main] org.tio.server.TioServer                 :
|----------------------------------------------------------------------------------------|
| TioConfig name    | BladeX-Mqtt-Server                                                 |
| Mica net version  | 1.0.13                                                             |
| Started at        | 2025-03-06 22:36:27                                                |
| Listen on         | 0.0.0.0:1883                                                       |
| Main Class        | org.springblade.mqtt.broker.BrokerApplication                      |
| Jvm start time    | 5672ms                                                             |
| Tio start time    | 3ms                                                                |
| Pid               | 35710                                                              |
|----------------------------------------------------------------------------------------|

2025-03-06 22:36:27.432  INFO 35710 --- [ntainer#1-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:36:27.433  INFO 35710 --- [       Thread-5] org.tio.utils.timer.TimingWheelThread    : Starting
2025-03-06 22:36:27.433  INFO 35710 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:36:27.433  INFO 35710 --- [           main] org.tio.server.TioServer                 :
|----------------------------------------------------------------------------------------|
| TioConfig name    | BladeX-Mqtt-Server-HTTP/Websocket                                  |
| Mica net version  | 1.0.13                                                             |
| Started at        | 2025-03-06 22:36:27                                                |
| Listen on         | 0.0.0.0:8083                                                       |
| Main Class        | org.springblade.mqtt.broker.BrokerApplication                      |
|----------------------------------------------------------------------------------------|

2025-03-06 22:36:27.433  INFO 35710 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.433  INFO 35710 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: need to re-join with the given member-id: consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4-7e7028ec-6a27-4d02-8107-424c848a544a
2025-03-06 22:36:27.433  INFO 35710 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:36:27.433  INFO 35710 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-4, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.435  INFO 35710 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: need to re-join with the given member-id: consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5-8621cc66-2354-46c3-996a-e29dac2040f0
2025-03-06 22:36:27.435  INFO 35710 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:36:27.435  INFO 35710 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_broker_c071fca2d9c64959cd1e06fbc00751ff-5, groupId=blade_broker_c071fca2d9c64959cd1e06fbc00751ff] (Re-)joining group
2025-03-06 22:36:27.657  INFO 35710 --- [           main] o.s.mqtt.broker.BrokerApplication        : Started BrokerApplication in 4.407 seconds (process running for 6.025)

五、启动数据流转服务 blade-data

由于 blade-data 为数据流转服务，暂时不对外公开API接口，所以无需配置 sign-key
前往BladeX-Links工程下的blade-data模块的application-dev.yml配置文件，修改kafka配置，若集群有多个节点则以逗号分隔
```
#kafka配置
spring:
  kafka:
    bootstrap-servers: 127.0.0.1:9092
```

前往BladeX-Links工程下的blade-data模块的application-dev.yml配置文件，database、redis、influxdb等配置

具体路径如下：BladeX-Links/blade-service/blade-data/src/main/resources/application-dev.yml
需要修改的配置如下(展示的为默认配置，实际情况请修改为自行设置的ip、端口、用户名、密码等配置)：

#数据源配置
spring:
  data:
    redis:
      ##redis 单机环境配置
      host: 127.0.0.1
      port: 6379
      password:
      database: 0
      ssl:
        enabled: false
      ##redis 集群环境配置
      #cluster:
      #  nodes: 127.0.0.1:7001,127.0.0.1:7002,127.0.0.1:7003
      #  commandTimeout: 5000
  datasource:
    url: jdbc:mysql://localhost:3306/bladex_iot?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
    username: root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver
  kafka:
    bootstrap-servers: 127.0.0.1:9092

#时序数据库配置
tdengine:
  enabled: true     # 是否开启，多个时序库插件依赖同时导入可采用此参数配置，开启的时序库
  username: root
  password: taosdata
  database: links   # 库名，会自动建库
  jdbc-url: jdbc:TAOS-RS://127.0.0.1:6041?useSSL=false
  # 数据精度，默认：毫秒
  precision: ms
  # 数据保存的天数，默认：10年
  keep: 3650
  # 批量写入相关配置
  enable-batch: true # 开启批量写，默认：开
  batch-size: 1000   # 批次大小，默认：1000
  flush-duration: 1s # 批次写入时间，默认：1s 写入一次
  # 连接池相关配置，可按需求进行配置，建议改大一些
  initial-size: 8    # 初始化的连接数，默认：8
  max-active: 32     # 最大活跃连接数，默认：32
  min-idle: 8        # 最小活跃连接数，默认：8
  max-wait: -1       # 最大等待时间，默认：-1 不限制

启动BladeX-Links工程下的blade-data模块的DataApplication启动类，看到如下日志，则说明启动成功

/Library/Java/JavaVirtualMachines/zulu-17.jdk/Contents/Home/bin/java -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:62804,suspend=y,server=n -agentpath:/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/idea_libasyncProfiler_dylib_temp_folder/libasyncProfiler.dylib=version,jfr,event=wall,interval=10ms,cstack=no,file=/Users/chill/IdeaSnapshots/DataApplication_2025_03_06_223441.jfr,log=/private/var/folders/m6/3wy47ml94pjddsjyf3db1d0w0000gn/T/DataApplication_2025_03_06_223441.jfr.log.txt,logLevel=DEBUG -XX:TieredStopAtLevel=1 -Dspring.output.ansi.enabled=always -Dcom.sun.management.jmxremote -Dspring.jmx.enabled=true -Dspring.liveBeansView.mbeanDomain -Dspring.application.admin.enabled=true -Dmanagement.endpoints.jmx.exposure.include=* -javaagent:/Users/chill/Library/Caches/JetBrains/IntelliJIdea2024.3/captureAgent/debugger-agent.jar -Dkotlinx.coroutines.debug.enable.creation.stack.trace=false -Ddebugger.agent.enable.coroutines=true -Dkotlinx.coroutines.debug.enable.flows.stack.trace=true -Dkotlinx.coroutines.debug.enable.mutable.state.flows.stack.trace=true -Dfile.encoding=UTF-8 -classpath /Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-data/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-base/target/classes:/Users/chill/.m2/repository/org/springblade/blade-core-launch/4.5.0/blade-core-launch-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-web/3.2.12/spring-boot-starter-web-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-json/3.2.12/spring-boot-starter-json-3.2.12.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jdk8/2.15.4/jackson-datatype-jdk8-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/module/jackson-module-parameter-names/2.15.4/jackson-module-parameter-names-2.15.4.jar:/Users/chill/.m2/repository/org/springframework/spring-web/6.1.15/spring-web-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-webmvc/6.1.15/spring-webmvc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-undertow/3.2.12/spring-boot-starter-undertow-3.2.12.jar:/Users/chill/.m2/repository/io/undertow/undertow-core/2.3.17.Final/undertow-core-2.3.17.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-api/3.8.16.Final/xnio-api-3.8.16.Final.jar:/Users/chill/.m2/repository/org/wildfly/common/wildfly-common/1.5.4.Final/wildfly-common-1.5.4.Final.jar:/Users/chill/.m2/repository/org/wildfly/client/wildfly-client-config/1.0.1.Final/wildfly-client-config-1.0.1.Final.jar:/Users/chill/.m2/repository/org/jboss/xnio/xnio-nio/3.8.16.Final/xnio-nio-3.8.16.Final.jar:/Users/chill/.m2/repository/org/jboss/threads/jboss-threads/3.5.0.Final/jboss-threads-3.5.0.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-servlet/2.3.17.Final/undertow-servlet-2.3.17.Final.jar:/Users/chill/.m2/repository/io/undertow/undertow-websockets-jsr/2.3.17.Final/undertow-websockets-jsr-2.3.17.Final.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-api/2.1.1/jakarta.websocket-api-2.1.1.jar:/Users/chill/.m2/repository/jakarta/websocket/jakarta.websocket-client-api/2.1.1/jakarta.websocket-client-api-2.1.1.jar:/Users/chill/.m2/repository/org/apache/tomcat/embed/tomcat-embed-el/10.1.33/tomcat-embed-el-10.1.33.jar:/Users/chill/.m2/repository/jakarta/servlet/jakarta.servlet-api/6.0.0/jakarta.servlet-api-6.0.0.jar:/Users/chill/.m2/repository/javax/xml/bind/jaxb-api/2.3.1/jaxb-api-2.3.1.jar:/Users/chill/.m2/repository/javax/activation/javax.activation-api/1.2.0/javax.activation-api-1.2.0.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-core/4.0.5/jaxb-core-4.0.5.jar:/Users/chill/.m2/repository/org/eclipse/angus/angus-activation/2.0.2/angus-activation-2.0.2.jar:/Users/chill/.m2/repository/com/sun/xml/bind/jaxb-impl/4.0.5/jaxb-impl-4.0.5.jar:/Users/chill/.m2/repository/javax/activation/activation/1.1.1/activation-1.1.1.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-mybatis/4.5.0/blade-starter-mybatis-4.5.0.jar:/Users/chill/.m2/repository/org/mybatis/mybatis/3.5.16/mybatis-3.5.16.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-spring/3.0.4/mybatis-spring-3.0.4.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus/3.5.8/mybatis-plus-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-core/3.5.8/mybatis-plus-core-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-annotation/3.5.8/mybatis-plus-annotation-3.5.8.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-extension/3.5.8/mybatis-plus-extension-3.5.8.jar:/Users/chill/.m2/repository/com/github/jsqlparser/jsqlparser/5.0/jsqlparser-5.0.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot-autoconfigure/3.5.8/mybatis-plus-spring-boot-autoconfigure-3.5.8.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-links-core/target/classes:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-common/3.1.11/mica-mqttx-common-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-mqttx-codec/3.1.11/mica-mqttx-codec-3.1.11.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-core/1.0.13/mica-net-core-1.0.13.jar:/Users/chill/.m2/repository/net/dreamlu/mica-net-utils/1.0.13/mica-net-utils-1.0.13.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-data-core/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-api/target/classes:/Users/chill/.m2/repository/com/github/ben-manes/caffeine/caffeine/3.1.8/caffeine-3.1.8.jar:/Users/chill/.m2/repository/org/checkerframework/checker-qual/3.37.0/checker-qual-3.37.0.jar:/Users/chill/.m2/repository/com/google/errorprone/error_prone_annotations/2.21.1/error_prone_annotations-2.21.1.jar:/Users/chill/.m2/repository/org/springblade/blade-core-boot/4.5.0/blade-core-boot-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-jdbc/3.2.12/spring-boot-starter-jdbc-3.2.12.jar:/Users/chill/.m2/repository/com/zaxxer/HikariCP/5.0.1/HikariCP-5.0.1.jar:/Users/chill/.m2/repository/org/springframework/spring-jdbc/6.1.15/spring-jdbc-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-beans/6.1.15/spring-beans-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-cache/3.2.12/spring-boot-starter-cache-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-context-support/6.1.15/spring-context-support-6.1.15.jar:/Users/chill/.m2/repository/org/springblade/blade-core-tool/4.5.0/blade-core-tool-4.5.0.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.15.4/jackson-datatype-jsr310-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.15.4/jackson-annotations-2.15.4.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.15.4/jackson-core-2.15.4.jar:/Users/chill/.m2/repository/com/google/guava/guava/33.1.0-jre/guava-33.1.0-jre.jar:/Users/chill/.m2/repository/com/google/guava/failureaccess/1.0.2/failureaccess-1.0.2.jar:/Users/chill/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/chill/.m2/repository/com/google/j2objc/j2objc-annotations/3.0.0/j2objc-annotations-3.0.0.jar:/Users/chill/.m2/repository/com/squareup/okhttp3/okhttp/4.12.0/okhttp-4.12.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio/3.6.0/okio-3.6.0.jar:/Users/chill/.m2/repository/com/squareup/okio/okio-jvm/3.6.0/okio-jvm-3.6.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-common/1.9.25/kotlin-stdlib-common-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk8/1.9.25/kotlin-stdlib-jdk8-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib/1.9.25/kotlin-stdlib-1.9.25.jar:/Users/chill/.m2/repository/org/jetbrains/annotations/13.0/annotations-13.0.jar:/Users/chill/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk7/1.9.25/kotlin-stdlib-jdk7-1.9.25.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-annotations-jakarta/2.2.19/swagger-annotations-jakarta-2.2.19.jar:/Users/chill/.m2/repository/org/bouncycastle/bcprov-jdk18on/1.78.1/bcprov-jdk18on-1.78.1.jar:/Users/chill/.m2/repository/org/springblade/blade-core-secure/4.5.0/blade-core-secure-4.5.0.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-impl/0.11.2/jjwt-impl-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-api/0.11.2/jjwt-api-0.11.2.jar:/Users/chill/.m2/repository/io/jsonwebtoken/jjwt-jackson/0.11.2/jjwt-jackson-0.11.2.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-cache/4.5.0/blade-starter-cache-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-log/4.5.0/blade-starter-log-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-swagger/4.5.0/blade-starter-swagger-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-jakarta-spring-boot-starter/4.5.0/knife4j-openapi3-jakarta-spring-boot-starter-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-core/4.5.0/knife4j-core-4.5.0.jar:/Users/chill/.m2/repository/com/github/xiaoymin/knife4j-openapi3-ui/4.5.0/knife4j-openapi3-ui-4.5.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-ui/2.3.0/springdoc-openapi-starter-webmvc-ui-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-webmvc-api/2.3.0/springdoc-openapi-starter-webmvc-api-2.3.0.jar:/Users/chill/.m2/repository/org/springdoc/springdoc-openapi-starter-common/2.3.0/springdoc-openapi-starter-common-2.3.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-core-jakarta/2.2.19/swagger-core-jakarta-2.2.19.jar:/Users/chill/.m2/repository/org/apache/commons/commons-lang3/3.13.0/commons-lang3-3.13.0.jar:/Users/chill/.m2/repository/io/swagger/core/v3/swagger-models-jakarta/2.2.19/swagger-models-jakarta-2.2.19.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.15.4/jackson-dataformat-yaml-2.15.4.jar:/Users/chill/.m2/repository/org/webjars/swagger-ui/5.10.3/swagger-ui-5.10.3.jar:/Users/chill/.m2/repository/com/baomidou/mybatis-plus-spring-boot3-starter/3.5.8/mybatis-plus-spring-boot3-starter-3.5.8.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-autoconfigure/3.2.12/spring-boot-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/mybatis/mybatis-typehandlers-jsr310/1.0.2/mybatis-typehandlers-jsr310-1.0.2.jar:/Users/chill/.m2/repository/net/sf/ehcache/ehcache/2.10.5/ehcache-2.10.5.jar:/Users/chill/.m2/repository/org/slf4j/slf4j-api/2.0.16/slf4j-api-2.0.16.jar:/Users/chill/.m2/repository/com/alibaba/druid-spring-boot-3-starter/1.2.23/druid-spring-boot-3-starter-1.2.23.jar:/Users/chill/.m2/repository/com/mysql/mysql-connector-j/8.3.0/mysql-connector-j-8.3.0.jar:/Users/chill/.m2/repository/com/google/protobuf/protobuf-java/3.25.1/protobuf-java-3.25.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-aop/3.2.12/spring-boot-starter-aop-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-aop/6.1.15/spring-aop-6.1.15.jar:/Users/chill/.m2/repository/org/aspectj/aspectjweaver/1.9.22.1/aspectjweaver-1.9.22.1.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-actuator/3.2.12/spring-boot-starter-actuator-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator-autoconfigure/3.2.12/spring-boot-actuator-autoconfigure-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-actuator/3.2.12/spring-boot-actuator-3.2.12.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-observation/1.12.13/micrometer-observation-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-commons/1.12.13/micrometer-commons-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-jakarta9/1.12.13/micrometer-jakarta9-1.12.13.jar:/Users/chill/.m2/repository/io/micrometer/micrometer-core/1.12.13/micrometer-core-1.12.13.jar:/Users/chill/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.12/HdrHistogram-2.1.12.jar:/Users/chill/.m2/repository/org/latencyutils/LatencyUtils/2.0.3/LatencyUtils-2.0.3.jar:/Users/chill/.m2/repository/org/springframework/retry/spring-retry/2.0.10/spring-retry-2.0.10.jar:/Users/chill/.m2/repository/org/hibernate/validator/hibernate-validator/8.0.1.Final/hibernate-validator-8.0.1.Final.jar:/Users/chill/.m2/repository/jakarta/validation/jakarta.validation-api/3.0.2/jakarta.validation-api-3.0.2.jar:/Users/chill/.m2/repository/org/jboss/logging/jboss-logging/3.5.3.Final/jboss-logging-3.5.3.Final.jar:/Users/chill/.m2/repository/com/fasterxml/classmate/1.6.0/classmate-1.6.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-tenant/4.5.0/blade-starter-tenant-4.5.0.jar:/Users/chill/.m2/repository/org/springblade/blade-starter-redis/4.5.0/blade-starter-redis-4.5.0.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-data-redis/3.2.12/spring-boot-starter-data-redis-3.2.12.jar:/Users/chill/.m2/repository/io/lettuce/lettuce-core/6.3.2.RELEASE/lettuce-core-6.3.2.RELEASE.jar:/Users/chill/.m2/repository/io/netty/netty-common/4.1.115.Final/netty-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-handler/4.1.115.Final/netty-handler-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-resolver/4.1.115.Final/netty-resolver-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-buffer/4.1.115.Final/netty-buffer-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.115.Final/netty-transport-native-unix-common-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-codec/4.1.115.Final/netty-codec-4.1.115.Final.jar:/Users/chill/.m2/repository/io/netty/netty-transport/4.1.115.Final/netty-transport-4.1.115.Final.jar:/Users/chill/.m2/repository/io/projectreactor/reactor-core/3.6.12/reactor-core-3.6.12.jar:/Users/chill/.m2/repository/org/reactivestreams/reactive-streams/1.0.4/reactive-streams-1.0.4.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-redis/3.2.12/spring-data-redis-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-keyvalue/3.2.12/spring-data-keyvalue-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/data/spring-data-commons/3.2.12/spring-data-commons-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/spring-oxm/6.1.15/spring-oxm-6.1.15.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-core/1.6.0/protostuff-core-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-api/1.6.0/protostuff-api-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-runtime/1.6.0/protostuff-runtime-1.6.0.jar:/Users/chill/.m2/repository/io/protostuff/protostuff-collectionschema/1.6.0/protostuff-collectionschema-1.6.0.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-mq-kafka/target/classes:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-mq-api/target/classes:/Users/chill/.m2/repository/org/springframework/kafka/spring-kafka/3.1.10/spring-kafka-3.1.10.jar:/Users/chill/.m2/repository/org/springframework/spring-context/6.1.15/spring-context-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-expression/6.1.15/spring-expression-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-messaging/6.1.15/spring-messaging-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-tx/6.1.15/spring-tx-6.1.15.jar:/Users/chill/.m2/repository/org/apache/kafka/kafka-clients/3.6.2/kafka-clients-3.6.2.jar:/Users/chill/.m2/repository/com/github/luben/zstd-jni/1.5.5-1/zstd-jni-1.5.5-1.jar:/Users/chill/.m2/repository/org/lz4/lz4-java/1.8.0/lz4-java-1.8.0.jar:/Users/chill/.m2/repository/org/xerial/snappy/snappy-java/1.1.10.5/snappy-java-1.1.10.5.jar:/Users/chill/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/Users/chill/Workspaces/product/BladeX-Links/blade-core/blade-tsdb-tdengine/target/classes:/Users/chill/.m2/repository/com/taosdata/jdbc/taos-jdbcdriver/3.5.1/taos-jdbcdriver-3.5.1.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpclient/4.5.14/httpclient-4.5.14.jar:/Users/chill/.m2/repository/org/apache/httpcomponents/httpcore/4.4.16/httpcore-4.4.16.jar:/Users/chill/.m2/repository/commons-codec/commons-codec/1.16.1/commons-codec-1.16.1.jar:/Users/chill/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.15.4/jackson-databind-2.15.4.jar:/Users/chill/.m2/repository/org/java-websocket/Java-WebSocket/1.5.4/Java-WebSocket-1.5.4.jar:/Users/chill/.m2/repository/com/alibaba/druid/1.2.23/druid-1.2.23.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter/3.2.12/spring-boot-starter-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot/3.2.12/spring-boot-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-starter-logging/3.2.12/spring-boot-starter-logging-3.2.12.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-classic/1.4.14/logback-classic-1.4.14.jar:/Users/chill/.m2/repository/ch/qos/logback/logback-core/1.4.14/logback-core-1.4.14.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-to-slf4j/2.21.1/log4j-to-slf4j-2.21.1.jar:/Users/chill/.m2/repository/org/apache/logging/log4j/log4j-api/2.21.1/log4j-api-2.21.1.jar:/Users/chill/.m2/repository/org/slf4j/jul-to-slf4j/2.0.16/jul-to-slf4j-2.0.16.jar:/Users/chill/.m2/repository/jakarta/annotation/jakarta.annotation-api/2.1.1/jakarta.annotation-api-2.1.1.jar:/Users/chill/.m2/repository/org/yaml/snakeyaml/2.2/snakeyaml-2.2.jar:/Users/chill/.m2/repository/jakarta/xml/bind/jakarta.xml.bind-api/4.0.2/jakarta.xml.bind-api-4.0.2.jar:/Users/chill/.m2/repository/jakarta/activation/jakarta.activation-api/2.1.3/jakarta.activation-api-2.1.3.jar:/Users/chill/.m2/repository/org/springframework/spring-core/6.1.15/spring-core-6.1.15.jar:/Users/chill/.m2/repository/org/springframework/spring-jcl/6.1.15/spring-jcl-6.1.15.jar:/Users/chill/.m2/repository/net/dreamlu/mica-auto/3.1.4/mica-auto-3.1.4.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-configuration-processor/3.2.12/spring-boot-configuration-processor-3.2.12.jar:/Users/chill/.m2/repository/org/springframework/boot/spring-boot-autoconfigure-processor/3.2.12/spring-boot-autoconfigure-processor-3.2.12.jar:/Users/chill/.m2/repository/org/projectlombok/lombok/1.18.36/lombok-1.18.36.jar:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar org.springblade.iot.data.DataApplication
Connected to the target VM, address: '127.0.0.1:62804', transport: 'socket'
----启动中，读取到的环境变量:[dev]，jar地址:[/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-data/target/classes/]----
  ____  _           _     __   __    _     _       _
|  _ \| |         | |    \ \ / /   | |   (_)     | |
| |_) | | __ _  __| | ___ \ V /    | |    _ _ __ | | _____
|  _ <| |/ _` |/ _` |/ _ \ > <     | |   | | '_ \| |/ / __|
| |_) | | (_| | (_| |  __// . \    | |___| | | | |   <\__ \
|____/|_|\__,_|\__,_|\___/_/ \_\   |_____|_|_| |_|_|\_\___/

:: BladeX :: blade-data:dev :: Running SpringBoot 3.2.12 ::

2025-03-06 22:34:42.230  INFO 35523 --- [kground-preinit] o.h.validator.internal.util.Version      : HV000001: Hibernate Validator 8.0.1.Final
2025-03-06 22:34:42.263  INFO 35523 --- [           main] o.springblade.iot.data.DataApplication   : Starting DataApplication using Java 17.0.10 with PID 35523 (/Users/chill/Workspaces/product/BladeX-Links/blade-service/blade-data/target/classes started by chill in /Users/chill/Workspaces/product/BladeX-Links)
2025-03-06 22:34:42.263 DEBUG 35523 --- [           main] o.springblade.iot.data.DataApplication   : Running with Spring Boot v3.2.12, Spring v6.1.15
2025-03-06 22:34:42.263  INFO 35523 --- [           main] o.springblade.iot.data.DataApplication   : The following 1 profile is active: "dev"
2025-03-06 22:34:42.935  INFO 35523 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
2025-03-06 22:34:42.937  INFO 35523 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2025-03-06 22:34:42.950  INFO 35523 --- [           main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 5 ms. Found 0 Redis repository interfaces.
2025-03-06 22:34:43.014  WARN 35523 --- [           main] o.m.s.mapper.ClassPathMapperScanner      : No MyBatis mapper was found in '[org.springblade.iot.data]' package. Please check your configuration.
2025-03-06 22:34:43.083  INFO 35523 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor init.
2025-03-06 22:34:43.109  INFO 35523 --- [           main] s.c.l.p.BladePropertySourcePostProcessor : BladePropertySourcePostProcessor process @BladePropertySource bean.
2025-03-06 22:34:43.305  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springblade.core.redis.config.RedisPubSubConfiguration' of type [org.springblade.core.redis.config.RedisPubSubConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). The currently created BeanPostProcessor [topicListenerDetector] is declared through a non-static factory method on that class; consider declaring it as static instead.
2025-03-06 22:34:43.313  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.data.redis-org.springframework.boot.autoconfigure.data.redis.RedisProperties' of type [org.springframework.boot.autoconfigure.data.redis.RedisProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.317  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration' of type [org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.319  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisConnectionDetails' of type [org.springframework.boot.autoconfigure.data.redis.PropertiesRedisConnectionDetails] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.323  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'spring.ssl-org.springframework.boot.autoconfigure.ssl.SslProperties' of type [org.springframework.boot.autoconfigure.ssl.SslProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.324  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.ssl.SslAutoConfiguration' of type [org.springframework.boot.autoconfigure.ssl.SslAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.326  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'fileWatcher' of type [org.springframework.boot.autoconfigure.ssl.FileWatcher] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.328  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'sslPropertiesSslBundleRegistrar' of type [org.springframework.boot.autoconfigure.ssl.SslPropertiesBundleRegistrar] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.331  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'sslBundleRegistry' of type [org.springframework.boot.ssl.DefaultSslBundleRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.333  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration' of type [org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.344  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.346  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleMetricsExportAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.347  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'management.simple.metrics.export-org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleProperties' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimpleProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.349  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'simpleConfig' of type [org.springframework.boot.actuate.autoconfigure.metrics.export.simple.SimplePropertiesConfigAdapter] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.352  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration' of type [org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.354  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'micrometerClock' of type [io.micrometer.core.instrument.Clock$1] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.362  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'simpleMeterRegistry' of type [io.micrometer.core.instrument.simple.SimpleMeterRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.372  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'micrometerOptions' of type [io.lettuce.core.metrics.MicrometerOptions] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.374  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'lettuceMetrics' of type [org.springframework.boot.actuate.autoconfigure.metrics.redis.LettuceMetricsAutoConfiguration$$Lambda$796/0x000000b0015c3388] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.421  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'lettuceClientResources' of type [io.lettuce.core.resource.DefaultClientResources] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.469  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisConnectionFactory' of type [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.483  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisMessageListenerContainer' of type [org.springframework.data.redis.listener.RedisMessageListenerContainer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.489  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springblade.core.redis.config.ProtoStuffSerializerConfiguration' of type [org.springblade.core.redis.config.ProtoStuffSerializerConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.513  WARN 35523 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'redisSerializer' of type [org.springblade.core.redis.serializer.ProtoStuffSerializer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying). Is this bean getting eagerly injected/applied to a currently created BeanPostProcessor [topicListenerDetector]? Check the corresponding BeanPostProcessor declaration and its dependencies/advisors. If this bean does not have to be post-processed, declare it with ROLE_INFRASTRUCTURE.
2025-03-06 22:34:43.659  WARN 35523 --- [           main] io.undertow.websockets.jsr               : UT026010: Buffer pool was not set on WebSocketDeploymentInfo, the default pool will be used
2025-03-06 22:34:43.667  INFO 35523 --- [           main] io.undertow.servlet                      : Initializing Spring embedded WebApplicationContext
2025-03-06 22:34:43.668  INFO 35523 --- [           main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 1384 ms
2025-03-06 22:34:43.899  INFO 35523 --- [           main] c.a.d.s.b.a.DruidDataSourceAutoConfigure : Init DruidDataSource
2025-03-06 22:34:44.023  INFO 35523 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-1} inited
2025-03-06 22:34:44.775  INFO 35523 --- [           main] o.s.core.boot.config.RetryConfiguration  : configServerRetryInterceptor: Changing backOffOptions to initial: 1000, multiplier: 1.2, maxInterval: 5000
2025-03-06 22:34:44.793  INFO 35523 --- [           main] o.s.core.log.logger.BladeLogger          : blade-data: BladeLogger init success!
2025-03-06 22:34:44.875  INFO 35523 --- [           main] o.s.c.redis.pubsub.RedisPubSubPublisher  : RPubSubPublisher init success.
2025-03-06 22:34:44.927  INFO 35523 --- [           main] o.s.c.r.pubsub.RPubSubListenerDetector   : Found @RPubSubListener on bean:org.springblade.iot.tsdb.config.IotTslCacheConfiguration$CacheUpdateListener method:public void org.springblade.iot.tsdb.config.IotTslCacheConfiguration$CacheUpdateListener.tslUpdateEvent(org.springblade.core.redis.pubsub.RPubSubEvent)
2025-03-06 22:34:45.390  INFO 35523 --- [           main] o.s.b.a.e.web.EndpointLinksResolver      : Exposing 1 endpoint(s) beneath base path '/actuator'
2025-03-06 22:34:45.455  INFO 35523 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create database sql:CREATE DATABASE IF NOT EXISTS links PRECISION 'ms' CACHEMODEL 'both' KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1

2025-03-06 22:34:45.600  INFO 35523 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_logger (`time` timestamp, `topic` NCHAR(128), `message` NCHAR(8192)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:45.638  INFO 35523 --- [           main] com.alibaba.druid.pool.DruidDataSource   : {dataSource-2} inited
2025-03-06 22:34:45.641  INFO 35523 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_event (`time` timestamp, `eventName` NCHAR(32), `identifier` NCHAR(32), `eventType` NCHAR(12), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:45.642  INFO 35523 --- [           main] o.s.i.t.tdengine.dao.TDEngineTemplate    : TdEngine create STable sql:CREATE STABLE IF NOT EXISTS device_command (`time` timestamp, `commandName` NCHAR(32), `identifier` NCHAR(32), `input` NCHAR(2048), `output` NCHAR(2048)) TAGS (`product_key` NCHAR(64), `device_name` NCHAR(64));
2025-03-06 22:34:45.709  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:45.709  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:45.709  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271685708
2025-03-06 22:34:45.905  INFO 35523 --- [| adminclient-1] o.a.kafka.common.utils.AppInfoParser     : App info kafka.admin.client for adminclient-1 unregistered
2025-03-06 22:34:45.907  INFO 35523 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Metrics scheduler closed
2025-03-06 22:34:45.907  INFO 35523 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2025-03-06 22:34:45.907  INFO 35523 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics    : Metrics reporters closed
2025-03-06 22:34:45.913  INFO 35523 --- [           main] io.undertow                              : starting server: Undertow - 2.3.17.Final
2025-03-06 22:34:45.917  INFO 35523 --- [           main] org.xnio                                 : XNIO version 3.8.16.Final
2025-03-06 22:34:45.922  INFO 35523 --- [           main] org.xnio.nio                             : XNIO NIO Implementation Version 3.8.16.Final
2025-03-06 22:34:45.932  INFO 35523 --- [           main] org.jboss.threads                        : JBoss Threads version 3.5.0.Final
2025-03-06 22:34:45.950  INFO 35523 --- [           main] o.s.b.w.e.undertow.UndertowWebServer     : Undertow started on port 9999 (http)
2025-03-06 22:34:45.952  INFO 35523 --- [sync-executor-1] o.s.core.launch.StartEventListener       : ---[BLADE-DATA]---启动完成，当前使用的端口:[9999]，环境变量:[dev]---
2025-03-06 22:34:45.990  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:45.990  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:45.990  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271685990
2025-03-06 22:34:45.995  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Subscribed to topic(s): blade_links_topo
2025-03-06 22:34:46.001  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.001  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.001  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686001
2025-03-06 22:34:46.003  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Subscribed to topic(s): blade_links_other_msg
2025-03-06 22:34:46.004  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.004  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.004  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686004
2025-03-06 22:34:46.006  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Subscribed to topic(s): blade_links_service
2025-03-06 22:34:46.007  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.007  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.007  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686007
2025-03-06 22:34:46.009  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Subscribed to topic(s): blade_links_property
2025-03-06 22:34:46.009  INFO 35523 --- [ntainer#7-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.009  INFO 35523 --- [ntainer#6-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.010  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.010  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.010  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686010
2025-03-06 22:34:46.011  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.011  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Subscribed to topic(s): blade_links_sub_register
2025-03-06 22:34:46.012  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.012  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.012  INFO 35523 --- [ntainer#2-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.012  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.012  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.013  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.013  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.013  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686013
2025-03-06 22:34:46.013  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.013  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Subscribed to topic(s): blade_links_ota
2025-03-06 22:34:46.015  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.015  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.015  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686015
2025-03-06 22:34:46.015  INFO 35523 --- [ntainer#3-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.015  INFO 35523 --- [ntainer#4-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.015  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.015  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.015  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.016  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.016  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Subscribed to topic(s): blade_links_status
2025-03-06 22:34:46.016  INFO 35523 --- [ntainer#5-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.016  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.017  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.018  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 3.6.2
2025-03-06 22:34:46.018  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: c4deed513057c94e
2025-03-06 22:34:46.018  INFO 35523 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1741271686018
2025-03-06 22:34:46.019  INFO 35523 --- [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.019  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.019  INFO 35523 --- [           main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Subscribed to topic(s): blade_links_event
2025-03-06 22:34:46.019  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-6-4b078a75-3b4f-4281-9e05-faebdec43bdd
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-2-712d7c3d-b027-4179-afa3-c1be47ec444b
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-1-621d74b3-3152-4f15-9809-9567801ac055
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-5-cf0856c8-44d8-449a-bc2f-8d7f821cfecb
2025-03-06 22:34:46.020  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-4-841df1c6-c3f3-4770-8a14-b300fcbcb212
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-3-5d4eac3f-38c9-495a-92ba-b7d761b9408e
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.021  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#1-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Cluster ID: VFTsWM6NSfyo2s3vKbjjhw
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-7-19fa9f89-cdfe-420e-8529-46004f32f7d8
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Discovered group coordinator localhost:9092 (id: 2147483646 rack: null)
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.022  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.024  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Request joining group due to: need to re-join with the given member-id: consumer-blade_data-8-7a182a47-83bd-4cf8-bcb7-bb88be017b01
2025-03-06 22:34:46.024  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException)
2025-03-06 22:34:46.024  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] (Re-)joining group
2025-03-06 22:34:46.242  INFO 35523 --- [           main] o.springblade.iot.data.DataApplication   : Started DataApplication in 4.237 seconds (process running for 4.67)
2025-03-06 22:34:46.448  INFO 35523 --- [-192.168.31.254] io.undertow.servlet                      : Initializing Spring DispatcherServlet 'dispatcherServlet'
2025-03-06 22:34:46.448  INFO 35523 --- [-192.168.31.254] o.s.web.servlet.DispatcherServlet        : Initializing Servlet 'dispatcherServlet'
2025-03-06 22:34:46.449  INFO 35523 --- [-192.168.31.254] o.s.web.servlet.DispatcherServlet        : Completed initialization in 1 ms
2025-03-06 22:34:49.027  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-7-19fa9f89-cdfe-420e-8529-46004f32f7d8', protocol='range'}
2025-03-06 22:34:49.027  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-6-4b078a75-3b4f-4281-9e05-faebdec43bdd', protocol='range'}
2025-03-06 22:34:49.027  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-5-cf0856c8-44d8-449a-bc2f-8d7f821cfecb', protocol='range'}
2025-03-06 22:34:49.028  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-4-841df1c6-c3f3-4770-8a14-b300fcbcb212', protocol='range'}
2025-03-06 22:34:49.028  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-8-7a182a47-83bd-4cf8-bcb7-bb88be017b01', protocol='range'}
2025-03-06 22:34:49.029  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-1-621d74b3-3152-4f15-9809-9567801ac055', protocol='range'}
2025-03-06 22:34:49.029  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-2-712d7c3d-b027-4179-afa3-c1be47ec444b', protocol='range'}
2025-03-06 22:34:49.027  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Successfully joined group with generation Generation{generationId=5, memberId='consumer-blade_data-3-5d4eac3f-38c9-495a-92ba-b7d761b9408e', protocol='range'}
2025-03-06 22:34:49.040  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Finished assignment for group at generation 5: {consumer-blade_data-1-621d74b3-3152-4f15-9809-9567801ac055=Assignment(partitions=[blade_links_topo-0]), consumer-blade_data-2-712d7c3d-b027-4179-afa3-c1be47ec444b=Assignment(partitions=[blade_links_other_msg-0]), consumer-blade_data-8-7a182a47-83bd-4cf8-bcb7-bb88be017b01=Assignment(partitions=[blade_links_event-0]), consumer-blade_data-4-841df1c6-c3f3-4770-8a14-b300fcbcb212=Assignment(partitions=[blade_links_property-0]), consumer-blade_data-6-4b078a75-3b4f-4281-9e05-faebdec43bdd=Assignment(partitions=[blade_links_ota-0]), consumer-blade_data-5-cf0856c8-44d8-449a-bc2f-8d7f821cfecb=Assignment(partitions=[blade_links_sub_register-0]), consumer-blade_data-3-5d4eac3f-38c9-495a-92ba-b7d761b9408e=Assignment(partitions=[blade_links_service-0]), consumer-blade_data-7-19fa9f89-cdfe-420e-8529-46004f32f7d8=Assignment(partitions=[blade_links_status-0])}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-4-841df1c6-c3f3-4770-8a14-b300fcbcb212', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-1-621d74b3-3152-4f15-9809-9567801ac055', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-2-712d7c3d-b027-4179-afa3-c1be47ec444b', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-3-5d4eac3f-38c9-495a-92ba-b7d761b9408e', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-5-cf0856c8-44d8-449a-bc2f-8d7f821cfecb', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-8-7a182a47-83bd-4cf8-bcb7-bb88be017b01', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-6-4b078a75-3b4f-4281-9e05-faebdec43bdd', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Successfully synced group in generation Generation{generationId=5, memberId='consumer-blade_data-7-19fa9f89-cdfe-420e-8529-46004f32f7d8', protocol='range'}
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_property-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_other_msg-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_event-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_service-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_topo-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_sub_register-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_ota-0])
2025-03-06 22:34:49.046  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Notifying assignor about the new Assignment(partitions=[blade_links_status-0])
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Adding newly assigned partitions: blade_links_event-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Adding newly assigned partitions: blade_links_property-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Adding newly assigned partitions: blade_links_service-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Adding newly assigned partitions: blade_links_status-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Adding newly assigned partitions: blade_links_topo-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Adding newly assigned partitions: blade_links_ota-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Adding newly assigned partitions: blade_links_other_msg-0
2025-03-06 22:34:49.047  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Adding newly assigned partitions: blade_links_sub_register-0
2025-03-06 22:34:49.054  INFO 35523 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-3, groupId=blade_data] Setting offset for partition blade_links_service-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-5, groupId=blade_data] Setting offset for partition blade_links_sub_register-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.054  INFO 35523 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-4, groupId=blade_data] Setting offset for partition blade_links_property-0 to the committed offset FetchPosition{offset=6, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.054  INFO 35523 --- [ntainer#5-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-6, groupId=blade_data] Setting offset for partition blade_links_ota-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#6-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-1, groupId=blade_data] Setting offset for partition blade_links_topo-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-7, groupId=blade_data] Setting offset for partition blade_links_status-0 to the committed offset FetchPosition{offset=2, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#7-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-2, groupId=blade_data] Setting offset for partition blade_links_other_msg-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-blade_data-8, groupId=blade_data] Setting offset for partition blade_links_event-0 to the committed offset FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:9092 (id: 1 rack: null)], epoch=0}}
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#6-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_topo-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#4-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_sub_register-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#7-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_other_msg-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#3-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_property-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#5-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_ota-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#2-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_service-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#1-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_event-0]
2025-03-06 22:34:49.055  INFO 35523 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : blade_data: partitions assigned: [blade_links_status-0]

六、注意事项

生产安全必看

上线后必须修改admin密码，防止被人恶意登录影响系统安全。
必须修改各数据库、redis的端口密码，防止被恶意程序扫描到。
熟读Blade安全手册，解决系统的安全隐患：点击查看