Unverified Commit 03a21e1a authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files
parent cc259ba0
Pipeline #13455 passed with stages
in 8 minutes and 21 seconds
......@@ -40,7 +40,7 @@ class KafkaTopology extends Logging {
val intermediaryReportingTopic = "import-process-ordered-service-reports"
val builder = new StreamsBuilder
val topicPattern = Pattern.compile(s"*.-${SettingsFromFile.getReportingInputTopicPostfix}" + "$")
val topicPattern = Pattern.compile(s".*${SettingsFromFile.getReportingInputTopicPostfix}" + "$")
val reportSource = builder.stream[String, String](topicPattern)
val orderedReportSource = builder.stream[String, Int](intermediaryReportingTopic)
......
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