Improve Zookeeper / Kafka Fixture management

  - spawn fixtures via daemon threads
  - close fixtures atexit and in __del__ to avoid interpreter hangs
  - raise Exception on timeouts in open()

1 files changed, 1 insertions, 0 deletions

diff --git a/test/service.py b/test/service.py
index ea29c33..0a9ee72 100644
--- a/test/service.py
+++ b/test/service.py
@@ -43,6 +43,7 @@ class SpawnedService(threading.Thread):
         self.should_die = threading.Event()
         self.child = None
         self.alive = False
+        self.daemon = True
 
     def run(self):
         self.run_with_handles()