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