Namespace für Konfig von `producer` in `juplo.producer` geändert

diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 69ac9863133e5cca481aca2c34fab5f9387ce345..5807af0f98a1c46de118fc848db180da198275a1 100644 (file)
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -192,9 +192,9 @@ services:
   producer:
     image: juplo/spring-producer:1.0-SNAPSHOT
     environment:
-      producer.bootstrap-server: kafka:9092
-      producer.client-id: producer
-      producer.topic: test
+      juplo.producer.bootstrap-server: kafka:9092
+      juplo.producer.client-id: producer
+      juplo.producer.topic: test
 
   consumer-1:
     image: juplo/simple-consumer:1.0-SNAPSHOT

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index ce532737cd32c50867a8ca50cf56a98b39ca78cf..54114eb75296844da72303b48808061b5e756727 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -10,7 +10,7 @@ import org.springframework.validation.annotation.Validated;
 import java.time.Duration;
 
 
-@ConfigurationProperties(prefix = "producer")
+@ConfigurationProperties(prefix = "juplo.producer")
 @Validated
 @Getter
 @Setter

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index ce7062929511d59f07f1825ec5cd652a368f6542..f0217a6ae89db77f227d69271105f1e9cdd91683 100644 (file)
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,11 +1,12 @@
-producer:
-  bootstrap-server: :9092
-  client-id: DEV
-  topic: test
-  acks: -1
-  batch-size: 16384
-  linger: 0
-  compression-type: gzip
+juplo:
+  producer:
+    bootstrap-server: :9092
+    client-id: DEV
+    topic: test
+    acks: -1
+    batch-size: 16384
+    linger: 0
+    compression-type: gzip
 management:
   endpoint:
     shutdown:
@@ -21,13 +22,13 @@ management:
       enabled: true
 info:
   kafka:
-    bootstrap-server: ${producer.bootstrap-server}
-    client-id: ${producer.client-id}
-    topic: ${producer.topic}
-    acks: ${producer.acks}
-    batch-size: ${producer.batch-size}
-    linger: ${producer.linger}
-    compression-type: ${producer.compression-type}
+    bootstrap-server: ${juplo.producer.bootstrap-server}
+    client-id: ${juplo.producer.client-id}
+    topic: ${juplo.producer.topic}
+    acks: ${juplo.producer.acks}
+    batch-size: ${juplo.producer.batch-size}
+    linger: ${juplo.producer.linger}
+    compression-type: ${juplo.producer.compression-type}
 logging:
   level:
     root: INFO

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 394007bdf52ce906239a0b92e3e097c9687e67f3..6d07e5ac4f77ba054f8aca373a46bb6595f513c7 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -29,8 +29,8 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
     properties = {
         "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
         "spring.kafka.consumer.auto-offset-reset=earliest",
-        "producer.bootstrap-server=${spring.embedded.kafka.brokers}",
-        "producer.topic=" + TOPIC})
+        "juplo.producer.bootstrap-server=${spring.embedded.kafka.brokers}",
+        "juplo.producer.topic=" + TOPIC})
 @AutoConfigureMockMvc
 @EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS)
 @Slf4j