From 5b80a5cee7a114a538ef43277a37e90de037da5b Mon Sep 17 00:00:00 2001 From: hoseinaghaei Date: Thu, 15 Feb 2024 08:27:49 +0330 Subject: [PATCH] fix. --- kafka_server/broker/file/read.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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()