Commit 03792a66 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Add filter for non-fatal reports in the outer loop.

parent 22934de8
Pipeline #27688 passed with stages
in 3 minutes and 38 seconds
......@@ -181,7 +181,11 @@ class BulkProcessor(
log.info("Adding consumer record ${it.key()} to bulk processor.")
listOf(add(it))
}
reports.forEach { report ->
// Only send these reports when they fail! Otherwise they will be duplicated. Fatal here means the
// request to ES could not be sent. (hopefully...)
reports
.filter { report -> report.status == ReportStatus.fatal }
.forEach { report ->
producer.sendReport(report, it.headers())
}
}
......
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