Commit 4948bc80 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Improve logging

parent 2fcdab85
......@@ -188,8 +188,10 @@ class KafkaTopology(
is RecordSetSearchDoc -> {
// Do not update if the name is already the same.
if (value.name == elasticSearchWrapper.getRecordSetName(value.id)) {
log.info("No update for record set name for ${value.name} as they are already current.")
KeyValue(key, null)
} else {
log.info("Updating names for record set ${value.id} in documents.")
KeyValue(
"$key#update",
updateQueryBuilder.updateRecordSetName(value.id, value.name)
......
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