Commit 84220cc9 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Add logging messages.

parent 592535f5
......@@ -256,6 +256,7 @@ class BulkProcessor(
)
val response = client.updateByQuery(request, RequestOptions.DEFAULT)
if (response.total > response.updated) {
log.info("Failed to update ${consumerRecord.key()} with ${response.total - response.updated} failures.")
response.bulkFailures.map {
Report(
consumerRecord.key(),
......@@ -265,6 +266,7 @@ class BulkProcessor(
)
}
} else {
log.info("Successfully updated ${consumerRecord.key()}.")
listOf(Report(
consumerRecord.key(),
ReportStatus.success,
......
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