diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py index 0227972..8cb9717 100644 --- a/kafka_server/broker/file/read.py +++ b/kafka_server/broker/file/read.py @@ -11,7 +11,6 @@ from file.segment import Segment from manager.env import get_partition_count - BROKER_PROJECT_PATH = os.getenv("BROKER_PROJECT_PATH", "/app/") sys.path.append(os.path.abspath(BROKER_PROJECT_PATH)) @@ -116,8 +115,7 @@ def ack_message(self): def check_data_exist(self): if self.segment.get_read_index() >= self.segment.get_write_index(): - print(f"No key found {self.segment.get_read_index()} " - f"in {self.segment.get_write_index()}") + print(f"No key found {self.segment.get_read_index()} in {self.segment.get_write_index()}") return False key, _ = self.segment.read()