diff --git a/Kafka/eventsim_producer.py b/Kafka/eventsim_producer.py
index ec65d68..492b8f1 100644
--- a/Kafka/eventsim_producer.py
+++ b/Kafka/eventsim_producer.py
@@ -9,10 +9,9 @@
 from kafka.admin import NewTopic
 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():