diff options
| -rw-r--r-- | test/test_producer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index de012b9..3004c2d 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -158,7 +158,7 @@ class TestKafkaProducerSendUpstream(unittest.TestCase): self.client.send_produce_request.side_effect = send_side_effect - self._run_process(3, 2) + self._run_process(3, 3) # the queue should be void at the end of the test self.assertEqual(self.queue.empty(), True) |