diff options
| -rw-r--r-- | test/test_client_integration.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index a6ea8f7..baaf79e 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -53,8 +53,8 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): @kafka_versions('all') def test_send_produce_request_maintains_request_response_order(self): - self.client.ensure_topic_exists(b'foo', timeout=1) - self.client.ensure_topic_exists(b'bar', timeout=1) + self.client.ensure_topic_exists(b'foo') + self.client.ensure_topic_exists(b'bar') requests = [ ProduceRequest( |