mqtt消费者失败放入es

sys-start/src/main/resources/bootstrap-prod.yml

@@ -1,7 +1,7 @@
 spring:
   mqtt:
     topics:
-      - { topic: "msgNotify", handler: com.xy.consumer.log.MsgConsumer }
+      - { topic: "msgNotify", handler: com.xy.consumer.MsgConsumer }
       - { topic: "log", handler: com.xy.consumer.log.LogConsumer }
       - { topic: "mqttConsumeErrorData", handler: com.xy.consumer.me.MqttConsumeErrorDataConsumer }
 

sys-start/src/main/resources/bootstrap-uat.yml

@@ -1,7 +1,7 @@
 spring:
   mqtt:
     topics:
-      - { topic: "msgNotify", handler: com.xy.consumer.log.MsgConsumer }
+      - { topic: "msgNotify", handler: com.xy.consumer.MsgConsumer }
       - { topic: "log", handler: com.xy.consumer.log.LogConsumer }
       - { topic: "mqttConsumeErrorData", handler: com.xy.consumer.me.MqttConsumeErrorDataConsumer }