학습 목표Structured Streaming이 unbounded 입력을 항상 켜진 job으로 처리하는 방식을 설명할 수 있다.micro-batch 실행 모델과 trigger·checkpoint 역할을 구분할 수 있다.event time·watermark로 늦게 도착한 이벤트를 다룰 수 있다.window 집계와 sink output mode를 선택할 수 있다.Kafka → Spark streaming → alert·table 파이프라인 초안을 설계할 수 있다.문제 상황5편 배치로 어제 dt 집계는 되는데 — 1분 단위 이상탐지는 cron으로 불가Kafka consumer lag는 쌓이는데 Spark job은 하루 한 번만 돈다processingTime 윈도우 썼더니 재시작 후 집계가 두 배 — check..