From e149318fa1034d7173cbe83334bf5d8c83ed1648 Mon Sep 17 00:00:00 2001
From: psmagin <pavlo_smahin@epam.com>
Date: Fri, 21 Jun 2024 18:13:04 +0300
Subject: [PATCH] - fix process

---
 .../org/folio/search/integration/KafkaMessageListener.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/folio/search/integration/KafkaMessageListener.java b/src/main/java/org/folio/search/integration/KafkaMessageListener.java
index cbda0c025..7c6315b0c 100644
--- a/src/main/java/org/folio/search/integration/KafkaMessageListener.java
+++ b/src/main/java/org/folio/search/integration/KafkaMessageListener.java
@@ -214,7 +214,10 @@ private void indexResources(List<ResourceEvent> batch, Consumer<List<ResourceEve
 
     for (var entry : batchByTenant.entrySet()) {
       folioMessageBatchProcessor.consumeBatchWithFallback(entry.getValue(), KAFKA_RETRY_TEMPLATE_NAME,
-        executionService.executeSystemUserScoped(entry.getKey(), () -> indexConsumer),
+        events -> executionService.executeSystemUserScoped(entry.getKey(), () -> {
+          indexConsumer.accept(events);
+          return null;
+        }),
         KafkaMessageListener::logFailedEvent);
     }
   }