await kafka shutdown to minimise errors reported in logs

2013-06-10 20:13:53 +01:00 · 2013-06-10 20:13:53 +01:00 · 52c61f12c1
commit 52c61f12c1
parent f9a1e978ca
1 changed files with 1 additions and 0 deletions
--- a/test/clj_kafka/test/utils.clj
+++ b/test/clj_kafka/test/utils.clj
@ -69,5 +69,6 @@
           (wait-until-initialised kafka# topic#))
         (try ~@body
              (finally (do (.shutdown kafka#)
+                           (.awaitShutdown kafka#)
                           (.shutdown zk#)
                           (FileUtils/deleteDirectory (file (tmp-dir)))))))))