Unverified Commit 5abc089c authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

fix wrongly named env var


Signed-off-by: Sebastian Schüpbach's avatarSebastian Schüpbach <sebastian.schuepbach@unibas.ch>
parent 4f86ad53
Pipeline #13084 passed with stages
in 8 minutes and 46 seconds
app:
countInputTopic: ${COUNT_INPUT_TOPIC:?system}
countTopicIn: ${COUNT_TOPIC_IN:?system}
kafka:
streams:
bootstrap.servers: ${KAFKA_BOOTSTRAP_SERVERS:?system}
......
......@@ -45,7 +45,7 @@ trait Settings {
*/
object SettingsFromFile extends Settings {
private val settings = new SettingsLoader(List(
"countInputTopic"
"countTopicIn"
).asJava,
"app.yml",
false,
......@@ -57,7 +57,7 @@ object SettingsFromFile extends Settings {
def getReportingInputTopic: String = settings.getInputTopic
override def getCountInputTopic: String = settings.getAppSettings.getProperty("countInputTopic")
override def getCountInputTopic: String = settings.getAppSettings.getProperty("countTopicIn")
def getKafkaOutputTopic: String = settings.getOutputTopic
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment