-package de.trion.microservices.validateorder;
+package de.trion.microservices.validateuser;
import org.springframework.boot.context.properties.ConfigurationProperties;
String bootstrapServers = "kafka:9092";
String schemaRegistryUrl = "http://schema-registry:8081";
String ordersTopic = "orders";
+ String usersTopic = "users";
String validationTopic = "validation";
this.ordersTopic = topic;
}
+ public String getUsersTopic()
+ {
+ return usersTopic;
+ }
+
+ public void setUsersTopic(String topic)
+ {
+ this.usersTopic = topic;
+ }
+
public String getValidationTopic()
{
return validationTopic;