TMP

[demos/microservices] / validate-user / src / main / java / de / trion / microservices / validateuser / ApplicationProperties.java

diff --git a/validate-user/src/main/java/de/trion/microservices/validateuser/ApplicationProperties.java b/validate-user/src/main/java/de/trion/microservices/validateuser/ApplicationProperties.java
index c632eef..2fad22d 100644 (file)
--- a/validate-user/src/main/java/de/trion/microservices/validateuser/ApplicationProperties.java
+++ b/validate-user/src/main/java/de/trion/microservices/validateuser/ApplicationProperties.java
@@ -1,15 +1,16 @@
-package de.trion.microservices.validateorder;
+package de.trion.microservices.validateuser;
 
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 
-@ConfigurationProperties("take-order")
+@ConfigurationProperties("validate-user")
 public class ApplicationProperties
 {
   String bootstrapServers = "kafka:9092";
   String schemaRegistryUrl = "http://schema-registry:8081";
   String ordersTopic = "orders";
+  String usersTopic = "users";
   String validationTopic = "validation";
 
 
@@ -43,6 +44,16 @@ public class ApplicationProperties
     this.ordersTopic = topic;
   }
 
+  public String getUsersTopic()
+  {
+    return usersTopic;
+  }
+
+  public void setUsersTopic(String topic)
+  {
+    this.usersTopic = topic;
+  }
+
   public String getValidationTopic()
   {
     return validationTopic;