mod-source-record-manager:

17:12:23.045 [vert.x-worker-thread-3] ERROR EventHandlingUtil    [5573911eqId] DI_SRS_MARC_AUTHORITY_RECORD_CREATED_Producer write error for event DI_SRS_MARC_AUTHORITY_RECORD_CREATED:
org.apache.kafka.common.errors.TimeoutException: Expiring 3 record(s) for FOLIO.Default.diku.DI_SRS_MARC_AUTHORITY_RECORD_CREATED-0:170192 ms has passed since batch creation

{"log":"19:25:37.971 [vert.x-worker-thread-4] ERROR PostgresClient       [13568837eqId] Timeout\n","stream":"stdout","time":"2022-02-02T19:25:37.971706669Z"}
{"log":"io.vertx.core.impl.NoStackTraceThrowable: Timeout\n","stream":"stdout","time":"2022-02-02T19:25:37.971833918Z"}
{"log":"19:25:37.971 [vert.x-worker-thread-4] ERROR utionProgressDaoImpl [13568837eqId] Rollback transaction. Failed to update jobExecutionProgress with job_execution_id: a175cbb7-0cd5-44ed-a496-49d23c9a7e18\n","stream":"stdout","time":"2022-02-02T19:25:37.972603937Z"}
{"log":"io.vertx.core.impl.NoStackTraceThrowable: Timeout\n","stream":"stdout","time":"2022-02-02T19:25:37.972650017Z"}
{"log":"19:25:37.973 [vert.x-worker-thread-4] ERROR tHandlingServiceImpl [13568839eqId] Failed to handle DI_COMPLETED event\n","stream":"stdout","time":"2022-02-02T19:25:37.974203219Z"}
{"log":"io.vertx.core.impl.NoStackTraceThrowable: Timeout\n","stream":"stdout","time":"2022-02-02T19:25:37.974237409Z"}
{"log":"19:25:38.002 [vert.x-worker-thread-12] ERROR taImportKafkaHandler [13568868eqId] Error during processing DataImport Result: \n","stream":"stdout","time":"2022-02-02T19:25:38.00220887Z"}
{"log":"19:25:38.002 [vert.x-worker-thread-12] DEBUG KafkaConsumerWrapper [13568868eqId] Consumer - id: 55 subscriptionPattern: SubscriptionDefinition(eventType=DI_COMPLETED, subscriptionPattern=FOLIO\\.Default\\.\\w{1,}\\.DI_COMPLETED) Committing offset: 25196\n","stream":"stdout","time":"2022-02-02T19:25:38.003997757Z"}
{"log":"19:25:38.002 [vert.x-worker-thread-12] ERROR KafkaConsumerWrapper [13568868eqId] Error while processing a record - id: 55 subscriptionPattern: SubscriptionDefinition(eventType=DI_COMPLETED, subscriptionPattern=FOLIO\\.Default\\.\\w{1,}\\.DI_COMPLETED) offset: 25196\n","stream":"stdout","time":"2022-02-02T19:25:38.004015753Z"}
{"log":"io.vertx.core.impl.NoStackTraceThrowable: null\n","stream":"stdout","time":"2022-02-02T19:25:38.004019961Z"}


mod-source-record-storage:

{"log":"16:57:13.987 [vert.x-kafka-consumer-thread-1] ERROR KafkaConsumerWrapper [4667345eqId] Error while KafkaConsumerWrapper is working: \n","stream":"stdout","time":"2022-02-02T16:57:13.99845873Z"}
{"log":"org.apache.kafka.clients.consumer.CommitFailedException: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group.\n","stream":"stdout","time":"2022-02-02T16:57:13.998467883Z"}
{"log":"\u0009at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.sendOffsetCommitRequest(ConsumerCoordinator.java:1134) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.99847133Z"}
{"log":"\u0009at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.commitOffsetsSync(ConsumerCoordinator.java:999) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998474384Z"}
{"log":"\u0009at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1504) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998477445Z"}
{"log":"\u0009at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:1452) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998480191Z"}
{"log":"\u0009at io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.lambda$commit$29(KafkaReadStreamImpl.java:611) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.99848368Z"}
{"log":"\u0009at io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.lambda$submitTaskWhenStarted$3(KafkaReadStreamImpl.java:135) ~[mod-source-record-storage-server-fat.jar:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998486701Z"}
{"log":"\u0009at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.99848951Z"}
{"log":"\u0009at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998498652Z"}
{"log":"\u0009at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998501377Z"}
{"log":"\u0009at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998504062Z"}
{"log":"\u0009at java.lang.Thread.run(Thread.java:829) [?:?]\n","stream":"stdout","time":"2022-02-02T16:57:13.998506978Z"}