From eba8e7b3a60c5a52a4188bd50f766002269011e9 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 29 Sep 2024 15:30:00 +0200 Subject: [PATCH] =?utf8?q?Namespace=20f=C3=BCr=20Konfig=20von=20`simple.co?= =?utf8?q?nsumer`=20in=20`juplo.consumer`=20ge=C3=A4ndert?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ApplicationProperties.java | 2 +- src/main/resources/application.yml | 4 ++-- src/test/java/de/juplo/kafka/ApplicationTests.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) 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 { -- 2.20.1