Reduce internal queue limit

kaufland-ecommerce · Jul 22, 2019 · d270ad1 · d270ad1
1 parent 51ec6a7
commit d270ad1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/esque/clients.py b/esque/clients.py
@@ -114,7 +114,7 @@ def get_file_writer(self, partition: int) -> FileWriter:
 class Producer(ABC):
     def __init__(self):
         self.queue_length = 100000
-        self.internal_queue_length_limit = self.queue_length / 0.8
+        self.internal_queue_length_limit = self.queue_length / 0.5
         self._config = Config().create_confluent_config()
         self._config.update(
             {