Stopping Zookeeper on EmbeddedKafka.stop()

Fixes #150

Author: manub

embedded-kafka/src/main/scala/net/manub/embeddedkafka/EmbeddedKafka.scala

@@ -79,7 +79,8 @@ object EmbeddedKafka extends EmbeddedKafkaSupport[EmbeddedKafkaConfig] {
     val broker =
       EmbeddedK(Option(factory), kafkaServer, kafkaLogsDir, actualConfig)
 
-    servers :+= broker
+    servers ++= Seq(broker, factory)
+
     broker
   }
 

embedded-kafka/src/main/scala/net/manub/embeddedkafka/EmbeddedServer.scala

@@ -29,7 +29,7 @@ case class EmbeddedZ(factory: ServerCnxnFactory, logsDirs: Directory)(
     *
     * @param clearLogs  pass `true` to recursively delete the log directory.
     */
-  override def stop(clearLogs: Boolean) = {
+  override def stop(clearLogs: Boolean): Unit = {
     factory.shutdown()
     if (clearLogs) logsDirs.deleteRecursively()
   }

embedded-kafka/src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaObjectSpec.scala

@@ -30,7 +30,7 @@ class EmbeddedKafkaObjectSpec extends EmbeddedKafkaSpecSupport {
       }
 
       "start and stop Kafka and Zookeeper on different specified ports using an implicit configuration" in {
-        implicit val config =
+        implicit val config: EmbeddedKafkaConfig =
           EmbeddedKafkaConfig(kafkaPort = 12345, zooKeeperPort = 54321)
         EmbeddedKafka.start()