kafka推送 交调数据

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) {

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);
     }