blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2021-12-28 6450fec60b8dc7e6d31779bcfe3b23b3f665ebaf 
 screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java


@@ -4,15 +4,12 @@


import com.moral.api.entity.Device;


import com.moral.api.entity.Sensor;


import com.moral.api.entity.UnitConversion;


import com.moral.api.utils.UnitConvertUtils;


import com.moral.api.websocket.SingleDeviceServer;


import com.moral.util.UnitConvertUtils;


import lombok.AllArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.kafka.clients.consumer.Consumer;


import org.apache.kafka.clients.consumer.ConsumerRecord;


import org.apache.kafka.common.TopicPartition;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.boot.context.properties.ConfigurationProperties;


import org.springframework.kafka.annotation.KafkaListener;


import org.springframework.kafka.listener.ConsumerSeekAware;


import org.springframework.stereotype.Component;