问题修改

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -355,8 +355,10 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                     jsonObjectXf.put("data", jsonObjects);
 
                     try {
-                        emqKeeper.getMqttClient().publish("eqm.xf.created",jsonObjectXf.toString().getBytes(),1,false);
+                        emqKeeper.getMqttClient().publish("emq.xf.created",jsonObjectXf.toString().getBytes(),1,false);
+                        log.info("遥测遥信数据推送云端kafka成功");
                     } catch (MqttException e) {
+                        log.error("遥测遥信数据推送云端kafka失败=====>" +  e.getMessage());
                         e.printStackTrace();
                     }