From b40337b77086d5417a0292ca767be8af4229be3c Mon Sep 17 00:00:00 2001 From: Maxence Cramet Date: Sat, 2 Jul 2016 15:11:23 -0400 Subject: [PATCH 1/2] Update Kafka version to 0.10.0.0 --- build.sbt | 2 +- src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaSpec.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/build.sbt b/build.sbt index f9515d2..653a943 100644 --- a/build.sbt +++ b/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, diff --git a/src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaSpec.scala b/src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaSpec.scala index 47fdff2..3c31dd7 100644 --- a/src/test/scala/net/manub/embeddedkafka/EmbeddedKafkaSpec.scala +++ b/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() } } From f7ec5c1962af9606e8474f88c95dbd1128ca3943 Mon Sep 17 00:00:00 2001 From: Maxence Cramet Date: Sat, 2 Jul 2016 15:11:23 -0400 Subject: [PATCH 2/2] Update Kafka version to 0.10.0.0 --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 0c41c6c..0c8d658 100644 --- a/README.md +++ b/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.*