commit be162c5295e9c68285125b431e233ec1b7a5c9e3
author Luca Milanesio <luca.milanesio@gmail.com> Wed Apr 22 18:10:38 2020 +0100
committer Luca Milanesio <luca.milanesio@gmail.com> Wed Apr 22 18:10:38 2020 +0100
tree da6781452d68be376f94ce9b362f745044dac965
parent 1ef9b338e6a31d8ce9ac5062c3a175183d2fb248

Do not listen for Kafka/Zookeeper on fixed ports

Change-Id: I89631dcd34b5b4057a8f90a8397989b9b4a4614c

src/test/java/com/googlesource/gerrit/plugins/kafka/api/KafkaBrokerApiTest.java

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 64a2973..fab4d3b 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
@@ -67,18 +67,6 @@
   private KafkaSession session;
   private Gson gson;
 
-  public static class TestKafkaContainer extends KafkaContainer {
-    public TestKafkaContainer() {
-      addFixedExposedPort(KAFKA_PORT, KAFKA_PORT);
-      addFixedExposedPort(ZOOKEEPER_PORT, ZOOKEEPER_PORT);
-    }
-
-    @Override
-    public String getBootstrapServers() {
-      return String.format("PLAINTEXT://%s:%s", getContainerIpAddress(), KAFKA_PORT);
-    }
-  }
-
   public static class TestWorkQueue extends WorkQueue {
 
     @Inject
@@ -143,7 +131,7 @@
 
   @BeforeClass
   public static void beforeClass() throws Exception {
-    kafka = new TestKafkaContainer();
+    kafka = new KafkaContainer();
     kafka.start();
     System.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafka.getBootstrapServers());
   }