kafka优化

zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java

@@ -533,10 +533,10 @@ public class DeviceMessageHandler {
      * @param msg 设备消息
      */
     private void oneStopDeviceMessageHandle(JSONObject msg) {
-        //kafka消息推送
-        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
 
         dcTrafficSectionDataService.processRealtimeOneStopMessage(msg);
+        //kafka消息推送
+        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
     }