Dump fixture logs on failure

1 files changed, 2 insertions, 0 deletions

diff --git a/test/fixtures.py b/test/fixtures.py
index c129adb..e50ce12 100644
--- a/test/fixtures.py
+++ b/test/fixtures.py
@@ -156,6 +156,7 @@ class ZookeeperFixture(Fixture):
             timeout = min(timeout, max(end_at - time.time(), 0))
             if self.child.wait_for(r"binding to port", timeout=timeout):
                 break
+            self.child.dump_logs()
             self.child.stop()
             timeout *= 2
             time.sleep(backoff)
@@ -305,6 +306,7 @@ class KafkaFixture(Fixture):
             if self.child.wait_for(r"\[Kafka Server %d\], Started" %
                                    self.broker_id, timeout=timeout):
                 break
+            self.child.dump_logs()
             self.child.stop()
             timeout *= 2
             time.sleep(backoff)