1.修改初始化配置

amos-boot-utils/amos-boot-utils-message/src/main/resources/application-roma.properties

@@ -10,7 +10,7 @@ eureka.instance.metadata-map.management.api-docs=http://localhost:${server.port}
 
 
 # kafka集群信息
-spring.kafka.bootstrap-servers=172.16.3.100:9092
+spring.kafka.bootstrap-servers=20.148.0.4:29094,20.148.0.5:29094,20.148.0.156:29094
 # 生产者配置
 # 设置大于0的值，则客户端会将发送失败的记录重新发送  # 重试次数
 spring.kafka.producer.retries=1
@@ -39,8 +39,8 @@ spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.Str
 spring.kafka.producer.properties.security.protocol=SASL_SSL
 spring.kafka.producer.properties.sasl.mechanism=PLAIN
 spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
-  username="io.cs" \
-  password="@$-5mocGV2n62K67GiMv9#sqvpaOu.0=%4y6vZ#cS#.@n2n-x5$n/35xfvSAKD12";
+  username="b05fbb3e-f994-44a3-834b-daed08e499e6" \
+  password="eQl/-7kK%/d%Vj=%3t0k/kC!#.2HZX2PWsz8qI0n-@c0h$O0d9@5e/774@!EVWi6";
 spring.kafka.producer.properties.ssl.truststore.location=D:/client.truststore.jks
 spring.kafka.producer.properties.ssl.truststore.password=dms@kafka
 spring.kafka.producer.properties.ssl.endpoint.identification.algorithm=
@@ -57,8 +57,8 @@ spring.kafka.consumer.enable-auto-commit=false
 spring.kafka.consumer.properties.security.protocol=SASL_SSL
 spring.kafka.consumer.properties.sasl.mechanism=PLAIN
 spring.kafka.consumer.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
-  username="io.cs" \
-  password="@$-5mocGV2n62K67GiMv9#sqvpaOu.0=%4y6vZ#cS#.@n2n-x5$n/35xfvSAKD12";
+  username="b05fbb3e-f994-44a3-834b-daed08e499e6" \
+  password="eQl/-7kK%/d%Vj=%3t0k/kC!#.2HZX2PWsz8qI0n-@c0h$O0d9@5e/774@!EVWi6";
 spring.kafka.consumer.properties.ssl.truststore.location=D:/client.truststore.jks
 spring.kafka.consumer.properties.ssl.truststore.password=dms@kafka
 spring.kafka.consumer.properties.ssl.endpoint.identification.algorithm=
@@ -98,17 +98,18 @@ emqx.client-password=public
 emqx.max-inflight=1000
 
 
-# 下面个配置默认站端  中心级系统的时候注释掉上边 放开下边
-#站端配置
+# 下面配置默认站端  中心级系统的时候注释掉上边 放开下边
+#站端配置开始
 #需要监听得kafka消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
 kafka.topics=JKXT2BP-XF-Topic
 
-#需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置 emq.iot.created,
+#需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
 emq.topic=emq.xf.created,emq.iot.created,emq.patrol.created,emq.sign.created,emq.bussSign.created,emq.user.created
+#站端配置结束
 
-##中心级配置配置
-##需要监听得kafka消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
-#kafka.topics=JKXT2BP-XFYY-Topic
-#
-##需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置 emq.iot.created,
-#emq.topic=
+#中心级配置配置开始
+#需要监听得kafka消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
+##kafka.topics=JKXT2BP-XFYY-Topic
+#需要监听得eqm消息主题 根据是否是中心极和站端选择需要监听得主题进行配置
+##emq.topic=
+#中心级配置配置结束
\ No newline at end of file