Commit 0dfdab65 authored by Matthias's avatar Matthias
Browse files

add headers for reporting

parent a25053ca
Pipeline #19422 failed with stages
in 1 minute and 7 seconds
......@@ -43,7 +43,7 @@ class Producer(
}
fun sendReport(report: Report) {
instance.send(ProducerRecord(reportingTopic, report.id, report.toJson()))
instance.send(ProducerRecord(reportingTopic, null, report.id, report.toJson()), headers)
}
override fun close() {
......
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