X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;h=dcac79bb8444322cd0a19a60fcff618f55f01ffa;hb=0c89ddec8156e2f44fe28c9d05fe06f548e9168e;hp=cded0ee30cd9a0d70fa3497518f37bca488ad2d1;hpb=21d88d8ede95d1f811ff91d3804cba6d95ae6aab;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 cded0ee..dcac79b 100644
--- a/src/test/java/de/juplo/kafka/ApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/ApplicationIT.java
@@ -8,14 +8,14 @@ import org.springframework.boot.test.web.client.TestRestTemplate;
 import org.springframework.boot.test.web.server.LocalServerPort;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 
-import static de.juplo.kafka.ApplicationTests.TOPIC;
+import static de.juplo.kafka.ApplicationIT.TOPIC;
 
 
 @SpringBootTest(
     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
     properties = {
-        "consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
-        "consumer.topic=" + TOPIC,
+        "sumup.adder.bootstrap-server=${spring.embedded.kafka.brokers}",
+        "sumup.adder.topic=" + TOPIC,
         "spring.mongodb.embedded.version=4.4.13" })
 @EmbeddedKafka(topics = TOPIC)
 @AutoConfigureDataMongo