Commit 458b14e4 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Fix reporting

parent 0b61b153
Pipeline #12323 passed with stages
in 5 minutes and 44 seconds
...@@ -50,13 +50,11 @@ class KafkaTopology(private val settings: SettingsLoader) { ...@@ -50,13 +50,11 @@ class KafkaTopology(private val settings: SettingsLoader) {
// report filtered error message from previous job. // report filtered error message from previous job.
errorFilter[0] errorFilter[0]
.mapValues { key, _ -> .mapValues { key, _ ->
Klaxon().toJsonString( Report(
Report( key,
key, ReportStatus.failure,
ReportStatus.failure, ReportMessages.processFailure(key, "The input file is invalid.")
ReportMessages.processFailure(key, "The input file is invalid.") ).toJson()
)
)
} }
.to("${settings.outputTopic}-reporting") .to("${settings.outputTopic}-reporting")
...@@ -74,7 +72,7 @@ class KafkaTopology(private val settings: SettingsLoader) { ...@@ -74,7 +72,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
1, 1,
0, 0,
1 1
) ).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