Commit c560ebab authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Add logging messages.

parent 84220cc9
Pipeline #26120 passed with stages
in 7 minutes and 59 seconds
......@@ -254,6 +254,7 @@ class BulkProcessor(
request.script = Script(
INLINE, "painless", updateQuery.source, updateQuery.params
)
log.info("Begin request for ${consumerRecord.key()}.")
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.")
......
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