@timestamp,@message,@logStream 2021-08-24 12:05:12.845,"12:05:12.844 [vert.x-worker-thread-1] INFO MarcRecordModifier [2267985424eqId] Field 001 ipvg000004374 was not updated, because it is protected",ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc 2021-08-24 12:05:12.845,"12:05:12.845 [vert.x-worker-thread-1] INFO MarcRecordModifier [2267985425eqId] Field 999 ff$idf746df1-26f8-442e-a018-f9939af2edaf$sc337f967-8da4-4f3a-bdc3-c7761197415b was not updated, because it is protected",ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc 2021-08-24 12:05:12.837,12:05:12.837 [vert.x-worker-thread-1] DEBUG taImportKafkaHandler [2267985417eqId] Data import event payload has been received with event type: DI_SRS_MARC_BIB_RECORD_MATCHED and correlationId: ace2c4a3-c9bb-4816-bb40-90c62f8f6208,ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc 2021-08-24 12:05:12.833,"12:05:12.833 [vert.x-worker-thread-1] DEBUG KafkaConsumerWrapper [2267985413eqId] Consumer - id: 5 subscriptionPattern: SubscriptionDefinition(eventType=DI_SRS_MARC_BIB_RECORD_MATCHED, subscriptionPattern=ism\.Default\.\w{1,}\.DI_SRS_MARC_BIB_RECORD_MATCHED) a Record has been received. key: 2 currentLoad: 1 globalLoad: 1",ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc 2021-08-24 12:05:12.729,12:05:12.728 [vert.x-worker-thread-18] INFO KafkaProducer [1188828477eqId] [Producer clientId=producer-8952] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.728,12:05:12.727 [vert.x-worker-thread-18] INFO KafkaEventPublisher [1188828476eqId] Event with type: DI_SRS_MARC_BIB_RECORD_MATCHED_READY_FOR_POST_PROCESSING and correlationId: ace2c4a3-c9bb-4816-bb40-90c62f8f6208 was sent to the topic ism.Default.fs00001060.DI_SRS_MARC_BIB_RECORD_MATCHED_READY_FOR_POST_PROCESSING,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.728,"12:05:12.728 [vert.x-worker-thread-18] DEBUG KafkaConsumerWrapper [1188828477eqId] Consumer - id: 11 subscriptionPattern: SubscriptionDefinition(eventType=DI_MARC_BIB_FOR_UPDATE_RECEIVED, subscriptionPattern=ism\.Default\.\w{1,}\.DI_MARC_BIB_FOR_UPDATE_RECEIVED) Committing offset: 5",ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.698,12:05:12.698 [kafka-producer-network-thread | producer-8952] INFO TransactionManager [1188828447eqId] [Producer clientId=producer-8952] ProducerId set to 1521966 with epoch 0,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.697,12:05:12.697 [vert.x-worker-thread-13] INFO ppInfoParser$AppInfo [1188828446eqId] Kafka startTimeMs: 1629806712695,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.697,12:05:12.697 [kafka-producer-network-thread | producer-8952] INFO Metadata [1188828446eqId] [Producer clientId=producer-8952] Cluster ID: xkkADBjHT6CBXqT80-05aA,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.696,12:05:12.696 [vert.x-worker-thread-13] INFO ppInfoParser$AppInfo [1188828445eqId] Kafka version: 2.5.0,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.696,12:05:12.696 [vert.x-worker-thread-13] INFO ppInfoParser$AppInfo [1188828445eqId] Kafka commitId: 66563e712b0b9f84,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.695,12:05:12.694 [vert.x-worker-thread-13] INFO KafkaProducer [1188828443eqId] [Producer clientId=producer-8952] Overriding the default retries config to the recommended value of 2147483647 since the idempotent producer is enabled.,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.695,12:05:12.695 [vert.x-worker-thread-13] INFO KafkaProducer [1188828444eqId] [Producer clientId=producer-8952] Overriding the default acks to all since idempotence is enabled.,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.690,12:05:12.690 [vert.x-worker-thread-13] INFO KafkaProducer [1188828439eqId] [Producer clientId=producer-8952] Instantiated an idempotent producer.,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689,12:05:12.688 [vert.x-worker-thread-13] INFO AbstractConfig [1188828437eqId] ProducerConfig values: ,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, acks = -1,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, batch.size = 16384,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, bootstrap.servers = [kafka.ism.folio-eis.us-east-1:9092],ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, buffer.memory = 33554432,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, client.dns.lookup = default,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, client.id = producer-8952,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, compression.type = none,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, connections.max.idle.ms = 540000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, delivery.timeout.ms = 120000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, enable.idempotence = true,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, interceptor.classes = [],ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, key.serializer = class org.apache.kafka.common.serialization.StringSerializer,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, linger.ms = 0,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, max.block.ms = 60000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, max.in.flight.requests.per.connection = 5,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, max.request.size = 1048576,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metadata.max.age.ms = 300000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metadata.max.idle.ms = 300000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metric.reporters = [],ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metrics.num.samples = 2,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metrics.recording.level = INFO,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, metrics.sample.window.ms = 30000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, receive.buffer.bytes = 32768,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, reconnect.backoff.max.ms = 1000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, reconnect.backoff.ms = 50,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, request.timeout.ms = 30000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, retries = 2147483647,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, retry.backoff.ms = 100,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.client.callback.handler.class = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.jaas.config = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.kerberos.kinit.cmd = /usr/bin/kinit,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.kerberos.min.time.before.relogin = 60000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.kerberos.service.name = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.kerberos.ticket.renew.jitter = 0.05,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.kerberos.ticket.renew.window.factor = 0.8,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.callback.handler.class = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.class = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.refresh.buffer.seconds = 300,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.refresh.min.period.seconds = 60,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.refresh.window.factor = 0.8,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.login.refresh.window.jitter = 0.05,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, sasl.mechanism = GSSAPI,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, security.protocol = PLAINTEXT,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, security.providers = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, send.buffer.bytes = 131072,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.cipher.suites = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.enabled.protocols = [TLSv1.2],ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.endpoint.identification.algorithm = https,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.key.password = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.keymanager.algorithm = SunX509,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.keystore.location = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.keystore.password = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.keystore.type = JKS,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.protocol = TLSv1.2,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.provider = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.secure.random.implementation = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.trustmanager.algorithm = PKIX,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.truststore.location = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.truststore.password = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, ssl.truststore.type = JKS,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, transaction.timeout.ms = 60000,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, transactional.id = null,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.689, value.serializer = class org.apache.kafka.common.serialization.StringSerializer,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.671,12:05:12.671 [vert.x-worker-thread-17] DEBUG taImportKafkaHandler [1188828420eqId] Data import event payload has been received with event type: DI_MARC_BIB_FOR_UPDATE_RECEIVED and correlationId: ace2c4a3-c9bb-4816-bb40-90c62f8f6208,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.666,"12:05:12.666 [vert.x-worker-thread-17] DEBUG KafkaConsumerWrapper [1188828415eqId] Consumer - id: 11 subscriptionPattern: SubscriptionDefinition(eventType=DI_MARC_BIB_FOR_UPDATE_RECEIVED, subscriptionPattern=ism\.Default\.\w{1,}\.DI_MARC_BIB_FOR_UPDATE_RECEIVED) a Record has been received. key: 2 currentLoad: 1 globalLoad: 1",ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.195,12:05:12.195 [vert.x-eventloop-thread-1] INFO LogUtil [1188827944eqId] 127.0.0.1:55952 PUT /source-storage/snapshots/da4f2d65-0d6a-4741-8ae6-4b35e0d46c77 HTTP_1_1 200 412 16 tid=fs00001060 OK ,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.194,12:05:12.194 [vert.x-eventloop-thread-1] INFO LogUtil [1188827943eqId] org.folio.rest.RestVerticle start invoking putSourceStorageSnapshotsByJobExecutionId,ism/mod-source-record-storage/63c1fbbbcee24165a946d623b850c4b6 2021-08-24 12:05:12.184,12:05:12.184 [vert.x-eventloop-thread-1] INFO LogUtil [2267984764eqId] 127.0.0.1:55358 PUT /source-storage/snapshots/da4f2d65-0d6a-4741-8ae6-4b35e0d46c77 HTTP_1_1 200 412 4 tid=fs00001060 OK ,ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc 2021-08-24 12:05:12.183,12:05:12.183 [vert.x-eventloop-thread-1] INFO LogUtil [2267984763eqId] org.folio.rest.RestVerticle start invoking putSourceStorageSnapshotsByJobExecutionId,ism/mod-source-record-storage/f5b0f3181f5946e9875404d38a1e89bc