X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;ds=inline;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;h=d1c8371813ed066059286f1d083aadfd1b6cd18f;hb=41e5f74b40e4a434483dcc4142aaf8224ea5a478;hp=ea1e43c577b4bd5843e5ab79c4a5948672cef22c;hpb=81c08612c6636a04864699233e7806d72e2ecf3a;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 ea1e43c..d1c8371 100644
--- a/src/test/java/de/juplo/kafka/ApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/ApplicationIT.java
@@ -7,16 +7,16 @@ 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.ApplicationTests.INPUT_TOPIC;
 
 
 @SpringBootTest(
     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
     properties = {
-        "consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
-        "consumer.topic=" + TOPIC,
+        "sumup.requests.bootstrap-server=${spring.embedded.kafka.brokers}",
+        "sumup.requests.topic=" + INPUT_TOPIC,
         "spring.mongodb.embedded.version=4.4.13" })
-@EmbeddedKafka(topics = TOPIC)
+@EmbeddedKafka(topics = INPUT_TOPIC)
 public class ApplicationIT
 {
   public static final String TOPIC = "FOO";