Skip to content

Commit 205dd4c

Browse files
committed
fix: adjust Kafka bootstrap and watchlist.txt path for runtime in Kubernetes
1 parent 00924a4 commit 205dd4c

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

app/config/kafka_consumer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from confluent_kafka import Consumer, KafkaException, KafkaError
22

33
conf = {
4-
"bootstrap.servers": "localhost:19092", # Kafka 브로커 주소
4+
"bootstrap.servers": "my-cluster-kafka-bootstrap.kafka:9092", # Kafka 브로커 주소
55
"group.id": "test-consumer-group", # 컨슈머 그룹 ID (아무거나 지정 가능)
66
"auto.offset.reset": "earliest" # 처음부터 읽기
77
}

app/config/kafka_producer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33

44
# Kafka 설정
55
conf = {
6-
"bootstrap.servers": "localhost:19092",
6+
"bootstrap.servers": "my-cluster-kafka-bootstrap.kafka:9092",
77
"client.id": socket.gethostname()
88
}
99

app/schedule/daily_quotes_scheduler.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ def get_watchlist_symbols():
1414
# 프로젝트 루트 디렉토리의 watchlist.txt 파일을 찾기
1515
import os
1616
current_dir = os.path.dirname(os.path.abspath(__file__))
17-
project_root = os.path.dirname(os.path.dirname(current_dir))
17+
project_root = os.path.dirname(current_dir)
1818
watchlist_path = os.path.join(project_root, "watchlist.txt")
1919

2020
with open(watchlist_path, "r", encoding="utf-8") as f:

0 commit comments

Comments
 (0)