add log on error.

mahdigheidi · Feb 15, 2024 · 0c14213 · 0c14213
1 parent 270f8c2
commit 0c14213
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py
@@ -150,7 +150,7 @@ def send_to_subscriber(self, key: str, value: str) -> bool:
 
         try:
             response = requests.post(url, json={'key': key, 'value': value}, timeout=2)
-            if response != 200:
+            if response.status_code != 200:
                 print(response.json(), response.content, response.status_code)
 
             return response.status_code == 200