3

data-storage/src/main/java/com/huaxing/mqtt/MqttMessageConsumer.java

@@ -51,9 +51,16 @@ public class MqttMessageConsumer extends MqttMessageReceiver {
                     analysisService.parseStoreData(payload);
                 });
             } else if (topic.contains("table-update/")){
+                // TODO 更新数据表字段
+                log.info("接收到table-update/的消息啦，快去处理");
+
+
+            } else if (topic.contains("table-add/")){
+                // TODO 创建Dfs/Stream数据表 建立订阅关系
+                log.info("接收到table-add/的消息啦，快去处理");
+
 
             }
-            // TODO 表更新topic
         } catch (Exception e) {
             log.error(e.toString());
         }