Update Kafka version to 0.10.0.0 (#27)

* Update Kafka version to 0.10.0.0

* Update Kafka version to 0.10.0.0

Author: max5599

README.md

@@ -1,5 +1,5 @@
 # scalatest-embedded-kafka
-A library that provides an in-memory Kafka broker to run your ScalaTest specs against. It uses Kafka 0.9.0.1 and ZooKeeper 3.4.7.
+A library that provides an in-memory Kafka broker to run your ScalaTest specs against. It uses Kafka 0.10.0.0 and ZooKeeper 3.4.7.
 
 The version supporting Kafka 0.8.x can be found [here](https://github.com/manub/scalatest-embedded-kafka/tree/kafka-0.8) - *this is no longer actively supported, although I'll be happy to accept PRs and produce releases.* 
 

build.sbt

@@ -11,7 +11,7 @@ lazy val commonSettings = Seq(
   parallelExecution in Test := false,
   libraryDependencies ++= Seq(
     "org.scalatest" %% "scalatest" % "2.2.5",
-    "org.apache.kafka" %% "kafka" % "0.9.0.1" exclude(slf4jLog4jOrg, slf4jLog4jArtifact),
+    "org.apache.kafka" %% "kafka" % "0.10.0.0" exclude(slf4jLog4jOrg, slf4jLog4jArtifact),
     "org.apache.zookeeper" % "zookeeper" % "3.4.7" exclude(slf4jLog4jOrg, slf4jLog4jArtifact),
     "org.apache.avro" % "avro" % "1.7.7" exclude(slf4jLog4jOrg, slf4jLog4jArtifact),
     "com.typesafe.akka" %% "akka-actor" % "2.3.14" % Test,

src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaSpec.scala

@@ -135,7 +135,7 @@ class EmbeddedKafkaSpec extends EmbeddedKafkaSpecSupport with EmbeddedKafka {
         val zkSecurityEnabled = false
 
         val zkUtils = ZkUtils(s"localhost:${config.zooKeeperPort}", zkSessionTimeoutMs, zkConnectionTimeoutMs, zkSecurityEnabled)
-        try { AdminUtils.fetchTopicMetadataFromZk(topic, zkUtils).partitionsMetadata.size shouldBe 2 } finally zkUtils.close()
+        try { AdminUtils.fetchTopicMetadataFromZk(topic, zkUtils).partitionMetadata().size shouldBe 2 } finally zkUtils.close()
 
       }
     }