Increased timeouts in EmbeddedKafka.

Author: manub

build.sbt

@@ -1,5 +1,7 @@
 import sbtrelease.Version
 
+parallelExecution in ThisBuild := false
+
 val kafkaVersion = "0.10.0.1"
 
 val slf4jLog4jOrg = "org.slf4j"
@@ -15,6 +17,7 @@ lazy val commonSettings = Seq(
   fork in Test := true
 )
 
+
 lazy val commonLibrarySettings = libraryDependencies ++= Seq(
   "org.scalatest" %% "scalatest" % "3.0.0",
   "org.apache.kafka" %% "kafka" % kafkaVersion exclude(slf4jLog4jOrg, slf4jLog4jArtifact),
@@ -51,9 +54,9 @@ lazy val releaseSettings = Seq(
 )
 
 lazy val root = (project in file("."))
-    .settings(name := "scalatest-embedded-kafka-root")
-    .settings(commonSettings: _*)
-    .aggregate(embeddedKafka, kafkaStreams)
+  .settings(name := "scalatest-embedded-kafka-root")
+  .settings(commonSettings: _*)
+  .aggregate(embeddedKafka, kafkaStreams)
 
 
 lazy val embeddedKafka = (project in file("embedded-kafka"))

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

@@ -168,7 +168,7 @@ sealed trait EmbeddedKafkaSupport {
                                    record: ProducerRecord[K, T]) = {
     val sendFuture = kafkaProducer.send(record)
     val sendResult = Try {
-      sendFuture.get(5, SECONDS)
+      sendFuture.get(10, SECONDS)
     }
 
     kafkaProducer.close()
@@ -179,7 +179,7 @@ sealed trait EmbeddedKafkaSupport {
 
   private def baseProducerConfig(implicit config: EmbeddedKafkaConfig) = Map(
     ProducerConfig.BOOTSTRAP_SERVERS_CONFIG -> s"localhost:${config.kafkaPort}",
-    ProducerConfig.MAX_BLOCK_MS_CONFIG -> 5000.toString,
+    ProducerConfig.MAX_BLOCK_MS_CONFIG -> 10000.toString,
     ProducerConfig.RETRY_BACKOFF_MS_CONFIG -> 1000.toString
   )