From ff492390b1e5c2e65d9fc0ed55d233ece33d5f3c Mon Sep 17 00:00:00 2001
From: chentaisen <14615430+chentaisen@user.noreply.gitee.com>
Date: Mon, 7 Oct 2024 09:58:50 +0800
Subject: [PATCH] =?UTF-8?q?feat():=E4=BF=AE=E6=94=B9=E6=A0=BC=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/muyu/parsing/mqtt/MqttTest.java    | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
index e2df8b6..ece270c 100644
--- a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
+++ b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
@@ -89,8 +89,15 @@ public class MqttTest {
                                 .value(value)
                                 .type("String")
                                 .build());
+                        kafKaDataList.add(KafKaData.builder()
+                                .key("firmCode")
+                                .label("企业编码")
+                                .value("firm01")
+                                .type("String")
+                                .build());
                     }
                     String jsonString = JSONObject.toJSONString(kafKaDataList);
+
                     ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString);
                     kafkaProducer.send(producerRecord);
                     log.info("kafka投产：{}", jsonString);
@@ -100,6 +107,8 @@ public class MqttTest {
 //                    System.out.println(jsonString);
                 }
 
+
+
                 // 接收信息
                 @Override
                 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {