🟢 실시간 데이터 스트리밍 처리 시스템

## 프로젝트 개요
입력된 데이터 스트림을 비동기적으로 처리하고 실시간으로 결과를 저장하는 시스템입니다. Clojure의 함수형 특성과 동시성 기능을 활용하여 안정적인 데이터 흐름 관리를 목표로 합니다.

## 주요 기능
- 입력 스트림에서 라인 단위로 데이터 추출
- 에러 발생 시 로그 기록 및 처리 중단 방지
- 처리 상태를 원자적으로 관리하여 병목 방지
- 결과 저장을 위한 간단한 출력 메커니즘 제공

## 사용 방법
1. `lein run` 명령어로 실행 (stdin에서 데이터 입력)
2. Ctrl+C로 중단 시 정상 종료 처리
3. `--output FILE` 옵션으로 로그 파일 저장 가능

## 확장 가능성
- Kafka/RabbitMQ 같은 메시지 큐 연동
- 추가 필터링/변환 로직 간단히 확장
- 병렬 처리도수 조절을 위한 스케일링 기능

(ns real-time-data-processing.core
  (:gen-class)
  (:require [clojure.core.async :as async]
            [clojure.java.io :as io]))

(def ^:dynamic *output-path* \