mqtt消费者失败放入es

sys-api-service/src/main/java/com/xy/entity/MqttConsumeErrorData.java

@@ -17,9 +17,9 @@ public class MqttConsumeErrorData {
     private String id;
 
     /**
-     * 分组
+     * topic
      */
-    private String group;
+    private String topic;
 
     /**
      * 内容

sys-api/src/main/java/com/xy/dto/MqttConsumeErrorDataDto.java

@@ -41,9 +41,9 @@ public class MqttConsumeErrorDataDto {
         private String id;
 
         /**
-         * 分组
+         * topic
          */
-        private String group;
+        private String topic;
 
         /**
          * 内容

sys-sdk/src/main/java/com/xy/utils/MqttConsumeErrorDataUtils.java

@@ -19,9 +19,9 @@ public class MqttConsumeErrorDataUtils {
     /**
      * 添加异常
      */
-    public static void save(String group, String msg) {
+    public static void save(String topic, String msg) {
         JSONObject jsonObject = new JSONObject()
-                .set("group", group)
+                .set("topic", topic)
                 .set("msg", msg)
                 .set("createTime", DataTime.getSring());
         mqttConsumeErrorDataProducer.sendToMqtt(jsonObject.toString(), LogsProducerConfiguration.TOPIC, 0);