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 376afdb..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
@@ -10,6 +10,7 @@ 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;