From: Kai Moritz <kai@juplo.de>
Date: Sun, 29 Sep 2024 13:30:00 +0000 (+0200)
Subject: Namespace für Konfig von `simple.consumer` in `juplo.consumer` geändert
X-Git-Tag: consumer/spring-consumer--BRANCH-ENDE~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=eba8e7b3a60c5a52a4188bd50f766002269011e9;p=demos%2Fkafka%2Ftraining

Namespace für Konfig von `simple.consumer` in `juplo.consumer` geändert
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index 43e15bf..463ea89 100644
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -8,7 +8,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.validation.annotation.Validated;
 
 
-@ConfigurationProperties(prefix = "simple.consumer")
+@ConfigurationProperties(prefix = "juplo.consumer")
 @Validated
 @Getter
 @Setter
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 50b114d..81fdca8 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,4 +1,4 @@
-simple:
+juplo:
   consumer:
     topics: test
 management:
@@ -19,7 +19,7 @@ info:
     bootstrap-server: ${spring.kafka.bootstrap-servers}
     client-id: ${spring.kafka.client-id}
     group-id: ${spring.kafka.consumer.group-id}
-    topics: ${simple.consumer.topics}
+    topics: ${juplo.consumer.topics}
     auto-offset-reset: ${spring.kafka.consumer.auto-offset-reset}
 spring:
   kafka:
diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index f317bf3..4df6f16 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -14,7 +14,7 @@ import static de.juplo.kafka.ApplicationTests.TOPIC;
     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
     properties = {
         "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
-        "simple.consumer.topics=" + TOPIC })
+        "juplo.consumer.topics=" + TOPIC })
 @EmbeddedKafka(topics = TOPIC)
 public class ApplicationTests
 {