Updated master branch to use Kafka 0.9.

Author: manub

README.md

@@ -1,13 +1,15 @@
 # scalatest-embedded-kafka
-A library that provides an in-memory Kafka broker to run your ScalaTest specs against. It uses Kafka 0.8.2.2 and ZooKeeper 3.4.6.
+A library that provides an in-memory Kafka broker to run your ScalaTest specs against. It uses Kafka 0.9.0.0 and ZooKeeper 3.4.7.
+
+**NOTE** the _master_ branch is now using Apache Kafka 0.9.x. The version supporting Kafka 0.8.x can be found [here](https://github.com/manub/scalatest-embedded-kafka/tree/kafka-0.8)
 
 Inspired by https://github.com/chbatey/kafka-unit
 
 ## How to use
 
 scalatest-embedded-kafka is available on Bintray and Maven Central, compiled for both Scala 2.10 and 2.11
 
-* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka" % "0.4.1" % "test"`
+* In your `build.sbt` file add the following dependency: `"net.manub" %% "scalatest-embedded-kafka" % "0.4.1-kafka09" % "test"`
 * Have your `Spec` extend the `EmbeddedKafka` trait.
 * Enclose the code that needs a running instance of Kafka within the `withRunningKafka` closure.
 

build.sbt

@@ -8,8 +8,8 @@ lazy val commonSettings = Seq(
   parallelExecution in Test := false,
   libraryDependencies ++= Seq(
     "org.scalatest" %% "scalatest" % "2.2.5",
-    "org.apache.kafka" %% "kafka" % "0.8.2.2",
-    "org.apache.zookeeper" % "zookeeper" % "3.4.6",
+    "org.apache.kafka" %% "kafka" % "0.9.0.0",
+    "org.apache.zookeeper" % "zookeeper" % "3.4.7",
     "org.apache.avro" % "avro" % "1.7.7",
 
     "com.typesafe.akka" %% "akka-actor" % "2.3.14" % Test,

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

@@ -104,7 +104,7 @@ sealed trait EmbeddedKafkaSupport {
 
     val kafkaProducer = new KafkaProducer(Map(
       ProducerConfig.BOOTSTRAP_SERVERS_CONFIG -> s"localhost:${config.kafkaPort}",
-      ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG -> 3000.toString,
+      ProducerConfig.MAX_BLOCK_MS_CONFIG -> 10000.toString,
       ProducerConfig.RETRY_BACKOFF_MS_CONFIG -> 1000.toString
     ), new StringSerializer, serializer)
 

version.sbt

@@ -1 +1 @@
-version in ThisBuild := "0.5.0-SNAPSHOT"
+version in ThisBuild := "0.4.1-kafka09-SNAPSHOT"