From abec7d778fd4b5c481ec2a6617b1d0d6c514a7f9 Mon Sep 17 00:00:00 2001
From: Yeojun <52143231+Yun024@users.noreply.github.com>
Date: Thu, 13 Mar 2025 21:42:24 +0900
Subject: [PATCH 1/2] =?UTF-8?q?[Update]Import=20Dir=20=EB=B3=80=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Kafka/eventsim_producer.py   | 6 +++---
 Kafka/register_connector.py  | 4 ++--
 Kafka/utils/connect_utils.py | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/Kafka/eventsim_producer.py b/Kafka/eventsim_producer.py
index ec65d68..7301692 100644
--- a/Kafka/eventsim_producer.py
+++ b/Kafka/eventsim_producer.py
@@ -10,9 +10,9 @@
 from kafka.errors import TopicAlreadyExistsError
 from kafka.producer import KafkaProducer
 
-from Kafka.model.music_streaming import EventLog
-from Kafka.utils.docker_utils import get_container_id, is_container_running
-from Kafka.utils.schema_utils import register_schema
+from model.music_streaming import EventLog
+from utils.docker_utils import get_container_id, is_container_running
+from utils.schema_utils import register_schema
 
 # Kafka 패키지가 있는 경로 추가
 BASE_DIR = os.path.dirname(os.path.abspath(__file__))
diff --git a/Kafka/register_connector.py b/Kafka/register_connector.py
index d9f0983..52e061e 100644
--- a/Kafka/register_connector.py
+++ b/Kafka/register_connector.py
@@ -1,8 +1,8 @@
 import os
 import sys
 
-from Kafka.utils.connect_utils import create_s3_sink_json
-from Kafka.utils.docker_utils import register_sink_connector
+from utils.connect_utils import create_s3_sink_json
+from utils.docker_utils import register_sink_connector
 
 BASE_DIR = os.path.dirname(os.path.abspath(__file__))
 sys.path.append(os.path.join(BASE_DIR, ".."))
diff --git a/Kafka/utils/connect_utils.py b/Kafka/utils/connect_utils.py
index 696725f..baaa745 100644
--- a/Kafka/utils/connect_utils.py
+++ b/Kafka/utils/connect_utils.py
@@ -1,7 +1,7 @@
 import json
 import os
 
-from Kafka.variables.aws_variables import aws_variables
+from variables.aws_variables import aws_variables
 
 
 def create_s3_sink_json():

From 28cea878032e2e8244814793abed7f659f6ab87a Mon Sep 17 00:00:00 2001
From: GitHub Action <action@github.com>
Date: Thu, 13 Mar 2025 12:43:08 +0000
Subject: [PATCH 2/2] Automated format fixes

---
 Kafka/eventsim_producer.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/Kafka/eventsim_producer.py b/Kafka/eventsim_producer.py
index 7301692..492b8f1 100644
--- a/Kafka/eventsim_producer.py
+++ b/Kafka/eventsim_producer.py
@@ -9,7 +9,6 @@
 from kafka.admin import NewTopic
 from kafka.errors import TopicAlreadyExistsError
 from kafka.producer import KafkaProducer
-
 from model.music_streaming import EventLog
 from utils.docker_utils import get_container_id, is_container_running
 from utils.schema_utils import register_schema