fix: DIA-1584: Allow input topic consumers to wait until the data is …

…ready
HumanSignal · Nov 7, 2024 · 07bdf8a · 07bdf8a
1 parent 882ca68
commit 07bdf8a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/utils.py b/server/utils.py
@@ -19,7 +19,7 @@ class Settings(BaseSettings):
 
     kafka_bootstrap_servers: Union[str, List[str]] = "localhost:9093"
     kafka_retention_ms: int = 180000  # 30 minutes
-    kafka_input_consumer_timeout_ms: int = 1500  # 1.5 seconds
+    kafka_input_consumer_timeout_ms: int = 15000  # 15 seconds
     kafka_output_consumer_timeout_ms: int = 1500  # 1.5 seconds
     task_time_limit_sec: int = 60 * 60 * 6  # 6 hours