fix.

mahdigheidi · Feb 15, 2024 · 46f9201 · 46f9201
1 parent d405801
commit 46f9201
Showing 1 changed file with 1 addition and 1 deletion.
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 % partition_count):
+            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)