Actually wait for kafka shutdown in withRunningKafka method.

Author: manub

src/main/scala/net/manub/embeddedkafka/EmbeddedKafka.scala

@@ -109,6 +109,7 @@ sealed trait EmbeddedKafkaSupport {
       body
     } finally {
       broker.shutdown()
+      broker.awaitShutdown()
       factory.shutdown()
     }
   }