diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-10 07:50:36 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-10 07:50:36 -0700 |
| commit | ded2ac7d321bab02c2b9fb3d8b03a60d6b9a5f84 (patch) | |
| tree | af7e958e12583b12db539748f2ee55c0b68eb5ac /test/test_client_integration.py | |
| parent | 8e3cd1ca2801ed13522d177305898c29a3ebfd9b (diff) | |
| download | kafka-python-ded2ac7d321bab02c2b9fb3d8b03a60d6b9a5f84.tar.gz | |
Remove 1 sec timeout on topic creation in client response ordering test
Diffstat (limited to 'test/test_client_integration.py')
| -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( |