From d270ad1f983391cf7f74aa83a9f5007a2bb6dcba Mon Sep 17 00:00:00 2001
From: Kevin Kreitner <kevin.kreitner@real-digital.de>
Date: Mon, 22 Jul 2019 16:12:52 +0200
Subject: [PATCH] Reduce internal queue limit

---
 esque/clients.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/esque/clients.py b/esque/clients.py
index a9107d45..3d2285f9 100644
--- 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(
             {