[KAFKA] 대용량 센서데이터 저장 처리 - 에뮬레이터 생성

앞서서는 환경설정이 끝났고이제 센서에서 초당 3200개의 데이터를 발생하는 에뮬레이터를 생성한다.우선 이번 페이지의 폴더구조는 다음과 같다.kafka-test├── docker-compose.yml ├── emulator └── sensor_emulator.py sensor_emulator.pyfrom kafka import KafkaProducerimport jsonimport timeimport randomimport threadingfrom datetime import datetime# kafka producer 설정producer = KafkaProducer( bootstrap_servers="localhost:9092", # Kafka 브로커 주소 value_serial..

2025.05.27