From f56787b5a8755899be6f970b4d7a9e6a63525177 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=99=A8=E5=93=80?= <2076029107@qq.com> Date: Fri, 4 Oct 2024 10:01:38 +0800 Subject: [PATCH] =?UTF-8?q?feat:()=20=E6=9D=A5=E7=B1=BB=E5=8A=A0=E6=B3=A8?= =?UTF-8?q?=E8=A7=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/muyu/processing/consumer/KafkaConsumerService.java | 1 + .../src/main/java/com/muyu/processing/utils/IotDb.java | 1 + 2 files changed, 2 insertions(+) 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