summaryrefslogtreecommitdiff
path: root/test/test_client_integration.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/test_client_integration.py')
-rw-r--r--test/test_client_integration.py11
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)