X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;h=3711a8337059dec1cc942abfb0b34fb7e1c3bdc5;hb=refs%2Ftags%2Fwip-merge-deserialization--sumup-adder--ohne-stored-offsets;hp=67b9d75830dfb3786052b44a572a3cfb16b9d648;hpb=66f52b33cb2380a7449ba6135f1b94a7bbe4d57d;p=demos%2Fkafka%2Ftraining diff --git a/src/test/java/de/juplo/kafka/ApplicationIT.java b/src/test/java/de/juplo/kafka/ApplicationIT.java index 67b9d75..3711a83 100644 --- a/src/test/java/de/juplo/kafka/ApplicationIT.java +++ b/src/test/java/de/juplo/kafka/ApplicationIT.java @@ -15,7 +15,8 @@ import static de.juplo.kafka.ApplicationIT.TOPIC; webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = { "consumer.bootstrap-server=${spring.embedded.kafka.brokers}", - "consumer.topic=" + TOPIC }) + "consumer.topic=" + TOPIC, + "spring.mongodb.embedded.version=4.4.13" }) @EmbeddedKafka(topics = TOPIC) @AutoConfigureDataMongo public class ApplicationIT