fix StartEmbeddedKafka

patschuh · Apr 17, 2024 · 357c4b4 · 357c4b4
1 parent 1f014de
commit 357c4b4
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 121 deletions.
diff --git a/src/test/java/at/esque/kafka/dialogs/TestDataProducer3.java b/src/test/java/at/esque/kafka/dialogs/TestDataProducer3.java
diff --git a/src/test/java/kafka/StartEmbeddedKafka.java b/src/test/java/kafka/StartEmbeddedKafka.java
@@ -3,6 +3,7 @@
 import org.junit.ClassRule;
 import org.junit.Ignore;
 import org.junit.Test;
+import org.springframework.kafka.test.EmbeddedKafkaBroker;
 import org.springframework.kafka.test.rule.EmbeddedKafkaRule;
 
 import static com.google.code.tempusfugit.concurrency.ThreadUtils.sleep;
@@ -13,10 +14,12 @@ public class StartEmbeddedKafka {
 
     @ClassRule
     public static EmbeddedKafkaRule embeddedKafkaRule =
-            new WindowsEmbeddedKafkaRule(1, true, "test.me").kafkaPorts(59000);
+            new EmbeddedKafkaRule(1, true, "test.me").kafkaPorts(59000);
 
     @Test
     public void startKafkaForManualTestsLaterWriterRealTests() {
+        EmbeddedKafkaBroker embeddedKafka = embeddedKafkaRule.getEmbeddedKafka();
+        embeddedKafka.afterPropertiesSet();
         sleep(seconds(60));
     }
 }
diff --git a/src/test/java/kafka/WindowsEmbeddedKafkaRule.java b/src/test/java/kafka/WindowsEmbeddedKafkaRule.java