Update fixtures to eliminate extraneous logging on non-errors, split out mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration

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):