diff --git a/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java b/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
index 49481bce..90d6f9be 100644
--- a/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
+++ b/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
@@ -11,7 +11,9 @@ public enum KafkEnum {
     //设备状态
     deviceStatus("deviceState"),
     // 视频AI
-    videoAI("eventAi");
+    videoAI("eventAi"),
+    //交通
+    surveyStation("surveyStation");
     private final String value;
 
     KafkEnum(String value) {
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 d23e9c69..5a47c9c6 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
@@ -509,6 +509,9 @@ public class DeviceMessageHandler {
      * @param msg 设备消息
      */
     private void oneStopDeviceMessageHandle(JSONObject msg) {
+        //kafka消息推送
+        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
+
         dcTrafficSectionDataService.processRealtimeOneStopMessage(msg);
     }