Set embedded Kafka server to use localhost as advertised name so it w…

…orks under all network conditions (#130)
cakesolutions · Feb 26, 2018 · 04db6a6 · 04db6a6
1 parent 1ce623b
commit 04db6a6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/testkit/src/main/scala/cakesolutions.kafka/testkit/KafkaServer.scala b/testkit/src/main/scala/cakesolutions.kafka/testkit/KafkaServer.scala
@@ -31,7 +31,8 @@ object KafkaServer {
   val defaultConfig: Map[String, String] = Map(
     KafkaConfig.BrokerIdProp  -> "1",
     KafkaConfig.ReplicaSocketTimeoutMsProp -> "1500",
-    KafkaConfig.ControlledShutdownEnableProp -> "true"
+    KafkaConfig.ControlledShutdownEnableProp -> "true",
+    KafkaConfig.AdvertisedHostNameProp -> "localhost"
   )
 
   /**