screen-api/src/main/java/com/moral/api/kafka/consumer/CruiserDataConsumer.java
@@ -1,5 +1,6 @@ package com.moral.api.kafka.consumer; import com.moral.api.utils.UnitConvertUtils; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.common.TopicPartition; @@ -22,7 +23,6 @@ import com.moral.api.entity.UnitConversion; import com.moral.api.websocket.CruiserWebSocketServer; import com.moral.constant.KafkaConstants; import com.moral.util.UnitConvertUtils; /* * 走航车数据消费者