Commit 01d2a55f authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Fix reporting

parent 458b14e4
Pipeline #12325 passed with stages
in 4 minutes and 35 seconds
...@@ -115,6 +115,7 @@ class KafkaTopology(private val settings: SettingsLoader) { ...@@ -115,6 +115,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
) )
} }
} }
.mapValues { value -> value.toJson() }
.to(settings.processReportTopic) .to(settings.processReportTopic)
} }
......
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