add log on error.

mahdigheidi · Feb 15, 2024 · 270f8c2 · 270f8c2
1 parent 2bc2687
commit 270f8c2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py
@@ -150,6 +150,9 @@ 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:
+                print(response.json(), response.content, response.status_code)
+
             return response.status_code == 200
         except Exception as e:
             print(e)