Feature/frb 145

[JuneSHYoo]

📌 PR 제목

[fix] kafka 리팩토링 및 로컬 소스 수정

---

✨ 변경 사항

• KafkaConsumer.java -> KafkaConsumer.java 와 SensorEventProcessor.java 로 분리

  KafkaConsumer.java : 공간 센서 Kafka 토픽으로부터 메시지를 수신
  SensorEventProcessor.java : 공산 센서 Kafka 메시지 처리

• kafka 관련 경로 수정

• 센서 데이터 인입시 isZone 추가 수정

  SensorService.java 의 saveSensor() 메서드 수정

• SensorKafkaDto.java dangerLevel추가

(as-is) 공간별 위험도 레벨 백엔드에서 판별 (to-be) FLINK에서 dangerLevel 판별 후 publish
변경사항에 맞게 관련 기능 수정

---

✅ 체크리스트

• 코드에 불필요한 부분은 없는가?
• 기능이 정상 동작하는가?
• 의존성은 문제가 없는가?
• 커밋 메시지는 명확한가?

---

📎 관련 이슈

• 관련된 이슈 번호: https://facto-real.atlassian.net/browse/FRB-145

---

💬 추가 설명

• 카프카쪽 변경사항이 많으니깐 pull 받을때 conflict 확인 꼭 해주세요