diff options
Diffstat (limited to 'test/test_client_integration.py')
| -rw-r--r-- | test/test_client_integration.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index e566cce..29a0cd0 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -22,11 +22,12 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): def test_timeout(self): server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) - server_socket.bind(('localhost', 14567)) + server_port = get_open_port() + server_socket.bind(('localhost', server_port)) with Timer() as t: with self.assertRaises((socket.timeout, socket.error)): - conn = kafka.conn.KafkaConnection("localhost", 14567, 1.0) + conn = kafka.conn.KafkaConnection("localhost", server_port, 1.0) self.assertGreaterEqual(t.interval, 1.0) def test_consume_none(self): |