本地运行&可视化

1. 本地运行&可视化

配置文件修改

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

使用内网IP地址，配置集群的本地IP，和集群IP

yaml

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

修改kafka服务地址 bootstrap-servers

yml

  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回令 如果必须等待回令,那么设置acks为all,否则，设置为-1,等待回令会有性能损耗
      retries: 3    # 重试次数
      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消息桥接转发的主题
      bridge-topics:
        - "property_post"
      enable: true

执行项目打包

修改 fmq-application 对应的 pom文件

注释配置，更新maven

xml

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