Commit 7d9b7d91 authored by Jonas Waeber's avatar Jonas Waeber

Improve logging

parent 27e79159
Pipeline #17089 canceled with stages
in 1 minute and 36 seconds
......@@ -87,11 +87,11 @@ class KafkaTopology(
)
parsedModelStream[1]
.mapValues { key, _ ->
.mapValues { key, value ->
Report(
key,
ReportStatus.failure,
"Could not parse message. Found invalid input data (RiotException)."
"Could not parse message. Found invalid input data (RiotException): $value"
).toJson()
}
.to(reportTopic)
......
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