Skip to content

Commit 3630e0c

Browse files
committed
Tune ZK/Kafka network binding configuration
1 parent 33feb85 commit 3630e0c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ sealed trait EmbeddedKafkaSupport {
217217
val zkServer = new ZooKeeperServer(zkLogsDir.toFile.jfile, zkLogsDir.toFile.jfile, tickTime)
218218

219219
val factory = ServerCnxnFactory.createFactory
220-
factory.configure(new InetSocketAddress("localhost", zooKeeperPort), 1024)
220+
factory.configure(new InetSocketAddress("0.0.0.0", zooKeeperPort), 1024)
221221
factory.startup(zkServer)
222222
factory
223223
}
@@ -229,6 +229,7 @@ sealed trait EmbeddedKafkaSupport {
229229
properties.setProperty("zookeeper.connect", zkAddress)
230230
properties.setProperty("broker.id", "0")
231231
properties.setProperty("host.name", "localhost")
232+
properties.setProperty("advertised.host.name", "localhost")
232233
properties.setProperty("auto.create.topics.enable", "true")
233234
properties.setProperty("port", config.kafkaPort.toString)
234235
properties.setProperty("log.dir", kafkaLogDir.toAbsolute.path)

0 commit comments

Comments
 (0)