2023-09-26 07:01:04.560 [vert.x-worker-thread-0] [077259/data-import] [diku] [e2a8dc0e-7c20-5311-936f-710b3f73e2ad] [] INFO  RecordDaoImpl        saveRecords:: Skipped saving records due to duplicate event: SQL Unique constraint violation prevented repeatedly saving the record
2023-09-26 07:01:04.560 [vert.x-worker-thread-0] [077259/data-import] [diku] [e2a8dc0e-7c20-5311-936f-710b3f73e2ad] [] WARN  RecordDaoImpl        saveRecords:: Error during batch record save
org.folio.kafka.exception.DuplicateEventException: SQL Unique constraint violation prevented repeatedly saving the record
	at org.folio.dao.RecordDaoImpl.lambda$47(RecordDaoImpl.java:689) ~[mod-source-record-storage-server-fat.jar:?]
	at java.util.ArrayList.forEach(Unknown Source) ~[?:?]
	at org.folio.dao.RecordDaoImpl.lambda$44(RecordDaoImpl.java:687) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.DefaultDSLContext.lambda$transaction$5(DefaultDSLContext.java:612) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.DefaultDSLContext.lambda$transactionResult0$3(DefaultDSLContext.java:550) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.Tools$3$1.block(Tools.java:5677) ~[mod-source-record-storage-server-fat.jar:?]
	at java.util.concurrent.ForkJoinPool.unmanagedBlock(Unknown Source) ~[?:?]
	at java.util.concurrent.ForkJoinPool.managedBlock(Unknown Source) ~[?:?]
	at org.jooq.impl.Tools$3.get(Tools.java:5674) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.DefaultDSLContext.transactionResult0(DefaultDSLContext.java:598) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.DefaultDSLContext.transactionResult(DefaultDSLContext.java:522) ~[mod-source-record-storage-server-fat.jar:?]
	at org.jooq.impl.DefaultDSLContext.transaction(DefaultDSLContext.java:611) ~[mod-source-record-storage-server-fat.jar:?]
	at org.folio.dao.RecordDaoImpl.lambda$37(RecordDaoImpl.java:621) ~[mod-source-record-storage-server-fat.jar:?]
	at io.vertx.core.impl.ContextBase.lambda$null$0(ContextBase.java:137) ~[mod-source-record-storage-server-fat.jar:?]
	at io.vertx.core.impl.ContextInternal.dispatch(ContextInternal.java:264) ~[mod-source-record-storage-server-fat.jar:?]
	at io.vertx.core.impl.ContextBase.lambda$executeBlocking$1(ContextBase.java:135) ~[mod-source-record-storage-server-fat.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[mod-source-record-storage-server-fat.jar:?]
	at java.lang.Thread.run(Unknown Source) ~[?:?]
2023-09-26 07:01:04.561 [vert.x-worker-thread-0] [077259/data-import] [diku] [e2a8dc0e-7c20-5311-936f-710b3f73e2ad] [] INFO  KafkaConsumerWrapper businessHandlerCompletionHandler:: Duplicate event for a record - id: 2 subscriptionPattern: SubscriptionDefinition(eventType=DI_RAW_RECORDS_CHUNK_PARSED, subscriptionPattern=FOLIO\.Default\.\w{1,}\.DI_RAW_RECORDS_CHUNK_PARSED) offset: 5 has been skipped, logging more info about it in error handler
2023-09-26 07:01:04.561 [vert.x-worker-thread-0] [077259/data-import] [diku] [e2a8dc0e-7c20-5311-936f-710b3f73e2ad] [] INFO  KafkaConsumerWrapper businessHandlerCompletionHandler:: Starting error handler to process failures for a record - id: 2 subscriptionPattern: SubscriptionDefinition(eventType=DI_RAW_RECORDS_CHUNK_PARSED, subscriptionPattern=FOLIO\.Default\.\w{1,}\.DI_RAW_RECORDS_CHUNK_PARSED) offset: 5 and send DI_ERROR events
2023-09-26 07:01:04.568 [vert.x-worker-thread-0] [077259/data-import] [diku] [e2a8dc0e-7c20-5311-936f-710b3f73e2ad] [] WARN  rdChunksErrorHandler handle:: Duplicate event received, skipping processing for jobExecutionId: 30160d5d-7527-4508-94ed-9f14f1e2d2a6 , tenantId: diku, correlationId:null, totalRecords: 6, cause: SQL Unique constraint violation prevented repeatedly saving the record