Merge pull request #37 from myNameIsPatrick/increase_timeout

producer.py: increase producer timeout to 10s
astronomy-commons · Jul 16, 2020 · ad9978c · ad9978c
2 parents 4fdeff9 + bafc5e0
commit ad9978c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/adc/producer.py b/adc/producer.py
@@ -73,7 +73,7 @@ class ProducerConfig:
 
     # produce_timeout sets the maximum amount of time that the backend can take
     # to send a message to Kafka. Use a value of 0 to never timeout.
-    produce_timeout = timedelta(seconds=2)
+    produce_timeout = timedelta(seconds=10)
 
     def _to_confluent_kafka(self) -> Dict:
         config = {