diff --git a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
index adc50d25..cf5b8ad6 100644
--- a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
+++ b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
@@ -5,6 +5,8 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.google.gson.Gson;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
 import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.spring.SpringUtils;
 import com.zc.business.constant.RedisKeyConstants;
@@ -97,7 +99,13 @@ public class DeviceMessageHandler {
        //state 设备状态 0 异常 1 正常
         Gson gson = new Gson();
         String jsonString = gson.toJson(dcDevices);
-        kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.deviceStatus.value());
+        JsonArray jsonArray = gson.fromJson(jsonString, JsonArray.class);
+        // 创建一个新的 JSON 对象，包装一层 "data"
+        JsonObject wrappedJson = new JsonObject();
+        wrappedJson.add("data", jsonArray);
+        // 将新的 JSON 对象转换为字符串
+        String wrappedJsonString = gson.toJson(wrappedJson);
+        kafkaTopicProducer.KafkaTopicProducer(wrappedJsonString, KafkEnum.deviceStatus.value());
 
        // 批量更新中间库设备状态
         middleDatabaseService.updateMiddleDatabaseDeviceByList(dcDevices);