本地運行&可視化

fastbee大約 1 分鐘

本地運行&可視化

配置文件修改

定位路徑 src\main\resources\application.yml

使用內(nèi)網(wǎng)IP地址，配置集群的本地IP，和集群IP

localAddress: 127.0.0.1
static-ip-addresses: 127.0.0.1, 1x.x.x.xx

修改kafka服務(wù)地址 bootstrap-servers

  kafka:
    broker-enabled: true   # 是否啟用kafka消息橋接
    bootstrap-servers: 127.0.0.1:9092    # kafka地址 127.0.0.1:9092,127.0.0.1:9093
    producer:
      acks: -1      # acks回令 如果必須等待回令,那么設(shè)置acks為all,否則，設(shè)置為-1,等待回令會有性能損耗
      retries: 3    # 重試次數(shù)
      batch-size: 16384      # 批量提交大小
      buffer-memory: 33554432   # 緩存大小
      key-serializer: org.apache.kafka.common.serialization.StringSerializer  #序列化方式
      value-serializer: org.apache.kafka.common.serialization.StringSerializer #序列化方式
      partitioner:
        class: cn.fastbee.iot.store.kafaka.MqttPartitioner
    message-bridge: # kafka消息橋接轉(zhuǎn)發(fā)的主題
      bridge-topics:
        - "property_post"
      enable: true

執(zhí)行項目打包

修改 fmq-application 對應(yīng)的 pom文件

注釋配置，更新maven

   <--     <resources>
            <resource>
                <directory>src/main/resources</directory>
                <excludes>
                    <exclude>application.yml</exclude>
                    <exclude>application-dev.yml</exclude>
                </excludes>
            </resource>
        </resources>  -->