- fix process

folio-org · Jun 21, 2024 · e149318 · e149318
1 parent 02d22e4
commit e149318
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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);
     }
   }