Commit 58281054 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Serialize report as json.

parent 892b1bd6
Pipeline #16035 passed with stages
in 5 minutes and 12 seconds
......@@ -119,7 +119,7 @@ class KafkaTopology(
val noRecordId = hasRecordId[1]
noRecordId
.mapValues { key, _ -> Report(key, ReportStatus.failure, "No record id found for record $key.") }
.mapValues { key, _ -> Report(key, ReportStatus.failure, "No record id found for record $key.").toJson() }
.to(reportTopic)
return hasRecordId[0]
......@@ -136,12 +136,12 @@ class KafkaTopology(
val noRecordTypeValue = hasRecordTypeValue[1]
noRecordTypeValue
.mapValues { key, value ->
.mapValues { key, _ ->
Report(
key,
ReportStatus.failure,
"No correct record type found for record $key."
)
).toJson()
}
.to(reportTopic)
......
Supports Markdown
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