diff options
Diffstat (limited to 'test/test_client_integration.py')
-rw-r--r-- | test/test_client_integration.py | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index b5bcb22..b33d17c 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -24,17 +24,6 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): cls.server.close() cls.zk.close() - @unittest2.skip("This doesn't appear to work on Linux?") - def test_timeout(self): - server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) - server_port = get_open_port() - server_socket.bind(('localhost', server_port)) - - with Timer() as t: - with self.assertRaises((socket.timeout, socket.error)): - kafka.conn.KafkaConnection("localhost", server_port, 1.0) - self.assertGreaterEqual(t.interval, 1.0) - @kafka_versions("all") def test_consume_none(self): fetch = FetchRequest(self.topic, 0, 0, 1024) |