Commit 2468c983 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Send successful report directly as outside

the report would be dropped.
parent 8da8ca6f
Pipeline #32136 passed with stages
in 4 minutes and 6 seconds
......@@ -278,14 +278,14 @@ class BulkProcessor(
}
} else {
log.info("Successfully updated ${consumerRecord.key()}.")
listOf(
producer.sendReport(
Report(
consumerRecord.key(),
ReportStatus.success,
"Successfully updated index $index.",
serviceName
)
)
), consumerRecord.headers())
listOf()
}
} catch (ex: Exception) {
......
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