WIP

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index bfb665f..d72ddfb 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -16,7 +16,12 @@ import static org.awaitility.Awaitility.*;
 
 
 @ExtendWith(SpringExtension.class)
-@EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS)
+@EmbeddedKafka(
+  topics = TOPIC,
+  partitions = PARTITIONS,
+  brokerProperties = {
+    "transaction.state.log.replication.factor=1",
+    "transaction.state.log.min.isr=1" })
 @Slf4j
 public class ApplicationTests
 {