X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fmicroservices;a=blobdiff_plain;f=validate-user%2Fsrc%2Fmain%2Fjava%2Fde%2Ftrion%2Fmicroservices%2Fvalidateuser%2FApplicationProperties.java;fp=validate-user%2Fsrc%2Fmain%2Fjava%2Fde%2Ftrion%2Fmicroservices%2Fvalidateuser%2FApplicationProperties.java;h=2fad22d3810f4689473a2685c4cb8e05c60d3774;hp=376afdba466af421f642fc40fa9fc91f8bf6f79f;hb=a249a48808e326b7d8a847e7429129c526dd9539;hpb=0e92e2fed82ca65a5650a4c52c015e80ccb64618 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 --- 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;