diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java index 6d92523..835f553 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java @@ -19,6 +19,7 @@ import java.time.Duration; import java.util.Collection; /** + * kafka消费者 * @Author:杨鹏 * @Package:com.muyu.processing.consumer * @Project:car-cloud-server diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/utils/IotDb.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/utils/IotDb.java index a36e2cb..c5e5cad 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/utils/IotDb.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/utils/IotDb.java @@ -13,6 +13,7 @@ import java.util.ArrayList; import java.util.List; /** + * IotDb测试 * @Author:杨鹏 * @Package:com.muyu.processing.utils * @Project:car-cloud-server