fix mod func.

mahdigheidi · Feb 15, 2024 · 7d3bd6a · 7d3bd6a
1 parent 5b80a5c
commit 7d3bd6a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/kafka_server/broker/file/segment.py b/kafka_server/broker/file/segment.py
@@ -41,7 +41,6 @@ def append(self, key: str, value: str):
             return False
         return True
 
-        # self.indexer.inc_write()
 
     def approve_appending(self):
         try:

diff --git a/kafka_server/broker/file/write.py b/kafka_server/broker/file/write.py
@@ -32,7 +32,7 @@ def write_data(self, key: str, value: str):
         with self._write_lock:
             md5 = hash_md5(key)
             partition_count = get_partition_count()
-            if int(md5, 16) % partition_count != int(self.partition) - 1:
+            if int(md5, 16) % partition_count != (int(self.partition) - 1 % partition_count):
                 raise Exception(f"key is not for this partition, fuck {md5} {key} {partition_count}")
 
             appended = self.segment.append(key, value)