diff --git a/src/test/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApiTest.java b/src/test/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApiTest.java
index 9078d05..eafa191 100644
--- a/src/test/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApiTest.java
+++ b/src/test/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApiTest.java
@@ -141,7 +141,7 @@
   public static void beforeClass() throws Exception {
     kafka = new TestKafkaContainer();
     kafka.start();
-    System.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9093");
+    System.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafka.getBootstrapServers());
 
     Injector baseInjector = Guice.createInjector(new TestModule());
     WorkQueue testWorkQueue = baseInjector.getInstance(WorkQueue.class);