diff --git a/src/main/java/org/folio/services/consortium/handler/ServicePointSynchronizationHandler.java b/src/main/java/org/folio/services/consortium/handler/ServicePointSynchronizationHandler.java index 6d2246e79..00b5dc08e 100644 --- a/src/main/java/org/folio/services/consortium/handler/ServicePointSynchronizationHandler.java +++ b/src/main/java/org/folio/services/consortium/handler/ServicePointSynchronizationHandler.java @@ -40,7 +40,7 @@ protected ServicePointSynchronizationHandler(ConsortiumDataCache consortiumDataC @Override public Future handle(KafkaConsumerRecord kafkaConsumerRecord) { - log.info("handle:: Processing event {}", kafkaConsumerRecord.topic()); + log.info("handle:: Processing event {}", kafkaConsumerRecord::topic); var headers = new CaseInsensitiveMap<>(KafkaHeaderUtils.kafkaHeadersToMap( kafkaConsumerRecord.headers())); return consortiumDataCache.getConsortiumData(headers)