timestamp,message 1695658304347, retry.backoff.ms = 100 1695658304347, sasl.client.callback.handler.class = null 1695658304347, sasl.jaas.config = null 1695658304347, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304347, sasl.kerberos.min.time.before.relogin = 60000 1695658304347, sasl.kerberos.service.name = null 1695658304347, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304347, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304347, sasl.login.callback.handler.class = null 1695658304347, sasl.login.class = null 1695658304347, sasl.login.connect.timeout.ms = null 1695658304347, sasl.login.read.timeout.ms = null 1695658304347, sasl.login.refresh.buffer.seconds = 300 1695658304347, sasl.login.refresh.min.period.seconds = 60 1695658304347, sasl.login.refresh.window.factor = 0.8 1695658304347, sasl.login.refresh.window.jitter = 0.05 1695658304347, sasl.login.retry.backoff.max.ms = 10000 1695658304347, sasl.login.retry.backoff.ms = 100 1695658304347, sasl.mechanism = GSSAPI 1695658304347, sasl.oauthbearer.clock.skew.seconds = 30 1695658304347, sasl.oauthbearer.expected.audience = null 1695658304347, sasl.oauthbearer.expected.issuer = null 1695658304347, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304347, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304347, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304347, sasl.oauthbearer.jwks.endpoint.url = null 1695658304347, sasl.oauthbearer.scope.claim.name = scope 1695658304347, sasl.oauthbearer.sub.claim.name = sub 1695658304347, sasl.oauthbearer.token.endpoint.url = null 1695658304347, security.protocol = PLAINTEXT 1695658304347, security.providers = null 1695658304347, send.buffer.bytes = 131072 1695658304347, socket.connection.setup.timeout.max.ms = 30000 1695658304347, socket.connection.setup.timeout.ms = 10000 1695658304347, ssl.cipher.suites = null 1695658304347," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304347, ssl.endpoint.identification.algorithm = null 1695658304347, ssl.engine.factory.class = null 1695658304347, ssl.key.password = null 1695658304347, ssl.keymanager.algorithm = SunX509 1695658304347, ssl.keystore.certificate.chain = null 1695658304347, ssl.keystore.key = null 1695658304347, ssl.keystore.location = null 1695658304347, ssl.keystore.password = null 1695658304347, ssl.keystore.type = JKS 1695658304347, ssl.protocol = TLSv1.2 1695658304347, ssl.provider = null 1695658304347, ssl.secure.random.implementation = null 1695658304347, ssl.trustmanager.algorithm = PKIX 1695658304347, ssl.truststore.certificates = null 1695658304347, ssl.truststore.location = null 1695658304347, ssl.truststore.password = null 1695658304347, ssl.truststore.type = JKS 1695658304347, transaction.timeout.ms = 60000 1695658304347, transactional.id = null 1695658304347, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304347,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349215] Instantiated an idempotent producer. 1695658304348,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349214] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_SRS_MARC_BIB_INSTANCE_HRID_SET-0 to 0 since the associated topicId changed from null to 8DLP8m8dTKKVjEQ7qe1ntw 1695658304348,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349214] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_SRS_MARC_BIB_INSTANCE_HRID_SET-1 to 0 since the associated topicId changed from null to 8DLP8m8dTKKVjEQ7qe1ntw 1695658304348,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349214] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304348,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349214] ProducerId set to 5730642 with epoch 0 1695658304348,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304348,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304348,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304348,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304348 1695658304349,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349215] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_LOG_SRS_MARC_BIB_RECORD_CREATED-0 to 0 since the associated topicId changed from null to 0xneTqT0Ruaxwu0X-1a1mA 1695658304349,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349215] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_LOG_SRS_MARC_BIB_RECORD_CREATED-1 to 0 since the associated topicId changed from null to 0xneTqT0Ruaxwu0X-1a1mA 1695658304349,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349215] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304349,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349215] ProducerId set to 5730643 with epoch 0 1695658304349,16:11:44 [] [] [] [] INFO AbstractConfig ProducerConfig values: 1695658304349, acks = -1 1695658304349, batch.size = 16384 1695658304349, bootstrap.servers = [kafka.ocp3.folio-eis.us-east-1:9092] 1695658304349, buffer.memory = 33554432 1695658304349, client.dns.lookup = use_all_dns_ips 1695658304349, client.id = producer-349216 1695658304349, compression.type = gzip 1695658304349, connections.max.idle.ms = 540000 1695658304349, delivery.timeout.ms = 120000 1695658304349, enable.idempotence = true 1695658304349, interceptor.classes = [] 1695658304349, key.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304349, linger.ms = 0 1695658304349, max.block.ms = 60000 1695658304349, max.in.flight.requests.per.connection = 5 1695658304349, max.request.size = 4000000 1695658304349, metadata.max.age.ms = 300000 1695658304349, metadata.max.idle.ms = 300000 1695658304349, metric.reporters = [] 1695658304349, metrics.num.samples = 2 1695658304349, metrics.recording.level = INFO 1695658304349, metrics.sample.window.ms = 30000 1695658304349, partitioner.adaptive.partitioning.enable = true 1695658304349, partitioner.availability.timeout.ms = 0 1695658304349, partitioner.class = null 1695658304349, partitioner.ignore.keys = false 1695658304349, receive.buffer.bytes = 32768 1695658304349, reconnect.backoff.max.ms = 1000 1695658304349, reconnect.backoff.ms = 50 1695658304349, request.timeout.ms = 30000 1695658304349, retries = 2147483647 1695658304349, retry.backoff.ms = 100 1695658304349, sasl.client.callback.handler.class = null 1695658304349, sasl.jaas.config = null 1695658304349, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304349, sasl.kerberos.min.time.before.relogin = 60000 1695658304349, sasl.kerberos.service.name = null 1695658304349, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304349, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304349, sasl.login.callback.handler.class = null 1695658304349, sasl.login.class = null 1695658304349, sasl.login.connect.timeout.ms = null 1695658304349, sasl.login.read.timeout.ms = null 1695658304349, sasl.login.refresh.buffer.seconds = 300 1695658304349, sasl.login.refresh.min.period.seconds = 60 1695658304349, sasl.login.refresh.window.factor = 0.8 1695658304349, sasl.login.refresh.window.jitter = 0.05 1695658304349, sasl.login.retry.backoff.max.ms = 10000 1695658304349, sasl.login.retry.backoff.ms = 100 1695658304349, sasl.mechanism = GSSAPI 1695658304349, sasl.oauthbearer.clock.skew.seconds = 30 1695658304349, sasl.oauthbearer.expected.audience = null 1695658304349, sasl.oauthbearer.expected.issuer = null 1695658304349, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304349, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304349, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304349, sasl.oauthbearer.jwks.endpoint.url = null 1695658304349, sasl.oauthbearer.scope.claim.name = scope 1695658304349, sasl.oauthbearer.sub.claim.name = sub 1695658304349, sasl.oauthbearer.token.endpoint.url = null 1695658304349, security.protocol = PLAINTEXT 1695658304349, security.providers = null 1695658304349, send.buffer.bytes = 131072 1695658304349, socket.connection.setup.timeout.max.ms = 30000 1695658304349, socket.connection.setup.timeout.ms = 10000 1695658304349, ssl.cipher.suites = null 1695658304349," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304349, ssl.endpoint.identification.algorithm = null 1695658304349, ssl.engine.factory.class = null 1695658304349, ssl.key.password = null 1695658304349, ssl.keymanager.algorithm = SunX509 1695658304349, ssl.keystore.certificate.chain = null 1695658304349, ssl.keystore.key = null 1695658304349, ssl.keystore.location = null 1695658304349, ssl.keystore.password = null 1695658304349, ssl.keystore.type = JKS 1695658304349, ssl.protocol = TLSv1.2 1695658304349, ssl.provider = null 1695658304349, ssl.secure.random.implementation = null 1695658304349, ssl.trustmanager.algorithm = PKIX 1695658304350, ssl.truststore.certificates = null 1695658304350, ssl.truststore.location = null 1695658304350, ssl.truststore.password = null 1695658304350, ssl.truststore.type = JKS 1695658304350, transaction.timeout.ms = 60000 1695658304350, transactional.id = null 1695658304350, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304350,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349216] Instantiated an idempotent producer. 1695658304350,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304350,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304350,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304350,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304350 1695658304352,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349216] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED-0 to 0 since the associated topicId changed from null to P6a0F0W6Qvud_iblaEnzRg 1695658304352,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349216] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED-1 to 0 since the associated topicId changed from null to P6a0F0W6Qvud_iblaEnzRg 1695658304352,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349216] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304352,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349216] ProducerId set to 5730644 with epoch 0 1695658304352,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 6 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_INSTANCE_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_INSTANCE_CREATED) Committed offset: 252230" 1695658304354,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 6 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_INSTANCE_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_INSTANCE_CREATED) Committed offset: 252231" 1695658304355,16:11:44 [] [] [] [] INFO EventHandlingUtil sendEventToKafka:: Event with type DI_LOG_SRS_MARC_BIB_RECORD_CREATED and recordId 1b6a3fce-faab-4b07-bff8-f59d0d6c9aaf with chunkId: null was sent to kafka 1695658304355,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349215] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 1695658304355,16:11:44 [] [] [] [] INFO EventHandlingUtil sendEventToKafka:: Event with type DI_SRS_MARC_BIB_INSTANCE_HRID_SET and recordId 1b6a3fce-faab-4b07-bff8-f59d0d6c9aaf with chunkId: null was sent to kafka 1695658304356,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349214] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 1695658304356,16:11:44 [] [] [] [] INFO Metrics Metrics scheduler closed 1695658304356,16:11:44 [] [] [] [] INFO Metrics Closing reporter org.apache.kafka.common.metrics.JmxReporter 1695658304356,16:11:44 [] [] [] [] INFO Metrics Metrics reporters closed 1695658304356,16:11:44 [] [] [] [] INFO AppInfoParser App info kafka.producer for producer-349215 unregistered 1695658304356,16:11:44 [] [] [] [] INFO Metrics Metrics scheduler closed 1695658304356,16:11:44 [] [] [] [] INFO Metrics Closing reporter org.apache.kafka.common.metrics.JmxReporter 1695658304356,16:11:44 [] [] [] [] INFO Metrics Metrics reporters closed 1695658304356,16:11:44 [] [] [] [] INFO AppInfoParser App info kafka.producer for producer-349214 unregistered 1695658304363,16:11:44 [] [] [] [] INFO KafkaEventPublisher publish:: Event with type: 'DI_INVENTORY_INSTANCE_CREATED' by jobExecutionId: 'd1e3edb6-0062-49c2-bbbe-9e49fd930479' and recordId: '1b6a3fce-faab-4b07-bff8-f59d0d6c9aaf' with chunkId: 'fb2747b3-7de0-4f6f-9586-69b701ccdf67' was sent to the topic 'ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED' 1695658304363,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349216] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 1695658304364,16:11:44 [] [] [] [] INFO Metrics Metrics scheduler closed 1695658304364,16:11:44 [] [] [] [] INFO Metrics Closing reporter org.apache.kafka.common.metrics.JmxReporter 1695658304364,16:11:44 [] [] [] [] INFO Metrics Metrics reporters closed 1695658304364,16:11:44 [] [] [] [] INFO AppInfoParser App info kafka.producer for producer-349216 unregistered 1695658304371,16:11:44 [] [] [] [] INFO ProfileSnapshotCache loadJobProfileSnapshot:: JobProfileSnapshot was loaded by id '7d99ebd7-6fd3-426c-a671-e07312fc466a' 1695658304373,16:11:44 [] [] [] [] INFO EventProcessorImpl process:: No suitable handler found for DI_INVENTORY_INSTANCE_CREATED event type and current profile ACTION_PROFILE 1695658304373,16:11:44 [] [] [] [] INFO EventProcessorImpl process:: No suitable handler found for DI_INVENTORY_HOLDING_CREATED event type and current profile ACTION_PROFILE 1695658304373,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 4 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_HOLDING_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_HOLDING_CREATED) Committed offset: 260024" 1695658304396,16:11:44 [] [] [] [] INFO ametersSnapshotCache loadMappingParametersSnapshot:: MappingParametersSnapshot was loaded by jobExecutionId 'd1e3edb6-0062-49c2-bbbe-9e49fd930479' 1695658304417,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 4 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_HOLDING_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_HOLDING_CREATED) Committed offset: 260025" 1695658304417,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 7 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING) Committed offset: 249404" 1695658304427,16:11:44 [] [] [] [] INFO ProfileSnapshotCache loadJobProfileSnapshot:: JobProfileSnapshot was loaded by id '7d99ebd7-6fd3-426c-a671-e07312fc466a' 1695658304429,16:11:44 [] [] [] [] INFO EventProcessorImpl process:: No suitable handler found for DI_INVENTORY_HOLDING_CREATED event type and current profile ACTION_PROFILE 1695658304432,16:11:44 [] [] [] [] INFO ProfileSnapshotCache loadJobProfileSnapshot:: JobProfileSnapshot was loaded by id '7d99ebd7-6fd3-426c-a671-e07312fc466a' 1695658304434,16:11:44 [] [] [] [] INFO EventProcessorImpl process:: No suitable handler found for DI_INVENTORY_HOLDING_CREATED event type and current profile ACTION_PROFILE 1695658304463,16:11:44 [] [] [] [] INFO ametersSnapshotCache loadMappingParametersSnapshot:: MappingParametersSnapshot was loaded by jobExecutionId 'd1e3edb6-0062-49c2-bbbe-9e49fd930479' 1695658304471,io.netty.channel.StacklessClosedChannelException 1695658304471," at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source)" 1695658304473,16:11:44 [] [] [] [] WARN ocessingEventHandler Failed to handle event DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING 1695658304473,io.netty.channel.StacklessClosedChannelException: null 1695658304473," at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[ms.jar:?]" 1695658304474,16:11:44 [] [] [] [] INFO AbstractConfig ProducerConfig values: 1695658304474, acks = -1 1695658304474, batch.size = 16384 1695658304474, bootstrap.servers = [kafka.ocp3.folio-eis.us-east-1:9092] 1695658304474, buffer.memory = 33554432 1695658304474, client.dns.lookup = use_all_dns_ips 1695658304474, client.id = producer-349217 1695658304474, compression.type = gzip 1695658304474, connections.max.idle.ms = 540000 1695658304474, delivery.timeout.ms = 120000 1695658304474, enable.idempotence = true 1695658304474, interceptor.classes = [] 1695658304474, key.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304474, linger.ms = 0 1695658304474, max.block.ms = 60000 1695658304474, max.in.flight.requests.per.connection = 5 1695658304474, max.request.size = 4000000 1695658304474, metadata.max.age.ms = 300000 1695658304474, metadata.max.idle.ms = 300000 1695658304474, metric.reporters = [] 1695658304474, metrics.num.samples = 2 1695658304474, metrics.recording.level = INFO 1695658304474, metrics.sample.window.ms = 30000 1695658304474, partitioner.adaptive.partitioning.enable = true 1695658304474, partitioner.availability.timeout.ms = 0 1695658304474, partitioner.class = null 1695658304474, partitioner.ignore.keys = false 1695658304474, receive.buffer.bytes = 32768 1695658304474, reconnect.backoff.max.ms = 1000 1695658304474, reconnect.backoff.ms = 50 1695658304474, request.timeout.ms = 30000 1695658304474, retries = 2147483647 1695658304474, retry.backoff.ms = 100 1695658304474, sasl.client.callback.handler.class = null 1695658304474, sasl.jaas.config = null 1695658304474, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304474, sasl.kerberos.min.time.before.relogin = 60000 1695658304474, sasl.kerberos.service.name = null 1695658304474, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304474, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304474, sasl.login.callback.handler.class = null 1695658304474, sasl.login.class = null 1695658304474, sasl.login.connect.timeout.ms = null 1695658304474, sasl.login.read.timeout.ms = null 1695658304474, sasl.login.refresh.buffer.seconds = 300 1695658304474, sasl.login.refresh.min.period.seconds = 60 1695658304474, sasl.login.refresh.window.factor = 0.8 1695658304474, sasl.login.refresh.window.jitter = 0.05 1695658304474, sasl.login.retry.backoff.max.ms = 10000 1695658304474, sasl.login.retry.backoff.ms = 100 1695658304474, sasl.mechanism = GSSAPI 1695658304474, sasl.oauthbearer.clock.skew.seconds = 30 1695658304474, sasl.oauthbearer.expected.audience = null 1695658304474, sasl.oauthbearer.expected.issuer = null 1695658304474, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304474, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304474, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304474, sasl.oauthbearer.jwks.endpoint.url = null 1695658304474, sasl.oauthbearer.scope.claim.name = scope 1695658304474, sasl.oauthbearer.sub.claim.name = sub 1695658304474, sasl.oauthbearer.token.endpoint.url = null 1695658304474, security.protocol = PLAINTEXT 1695658304474, security.providers = null 1695658304474, send.buffer.bytes = 131072 1695658304474, socket.connection.setup.timeout.max.ms = 30000 1695658304474, socket.connection.setup.timeout.ms = 10000 1695658304474, ssl.cipher.suites = null 1695658304474," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304474, ssl.endpoint.identification.algorithm = null 1695658304474, ssl.engine.factory.class = null 1695658304474, ssl.key.password = null 1695658304474, ssl.keymanager.algorithm = SunX509 1695658304474, ssl.keystore.certificate.chain = null 1695658304474, ssl.keystore.key = null 1695658304474, ssl.keystore.location = null 1695658304474, ssl.keystore.password = null 1695658304474, ssl.keystore.type = JKS 1695658304474, ssl.protocol = TLSv1.2 1695658304474, ssl.provider = null 1695658304474, ssl.secure.random.implementation = null 1695658304474, ssl.trustmanager.algorithm = PKIX 1695658304474, ssl.truststore.certificates = null 1695658304474, ssl.truststore.location = null 1695658304474, ssl.truststore.password = null 1695658304474, ssl.truststore.type = JKS 1695658304474, transaction.timeout.ms = 60000 1695658304474, transactional.id = null 1695658304474, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304474,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349217] Instantiated an idempotent producer. 1695658304475,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304475,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304475,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304475,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304475 1695658304476,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349217] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_ERROR-0 to 0 since the associated topicId changed from null to XUKjtiqIQxWu-quJUFdCBg 1695658304476,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349217] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_ERROR-1 to 0 since the associated topicId changed from null to XUKjtiqIQxWu-quJUFdCBg 1695658304476,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349217] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304476,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349217] ProducerId set to 5730645 with epoch 0 1695658304483,16:11:44 [] [] [] [] INFO AbstractConfig ProducerConfig values: 1695658304483, acks = -1 1695658304483, batch.size = 16384 1695658304483, bootstrap.servers = [kafka.ocp3.folio-eis.us-east-1:9092] 1695658304483, buffer.memory = 33554432 1695658304483, client.dns.lookup = use_all_dns_ips 1695658304483, client.id = producer-349218 1695658304483, compression.type = gzip 1695658304483, connections.max.idle.ms = 540000 1695658304483, delivery.timeout.ms = 120000 1695658304483, enable.idempotence = true 1695658304483, interceptor.classes = [] 1695658304483, key.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304483, linger.ms = 0 1695658304483, max.block.ms = 60000 1695658304483, max.in.flight.requests.per.connection = 5 1695658304483, max.request.size = 4000000 1695658304483, metadata.max.age.ms = 300000 1695658304483, metadata.max.idle.ms = 300000 1695658304483, metric.reporters = [] 1695658304483, metrics.num.samples = 2 1695658304483, metrics.recording.level = INFO 1695658304483, metrics.sample.window.ms = 30000 1695658304483, partitioner.adaptive.partitioning.enable = true 1695658304483, partitioner.availability.timeout.ms = 0 1695658304483, partitioner.class = null 1695658304483, partitioner.ignore.keys = false 1695658304483, receive.buffer.bytes = 32768 1695658304483, reconnect.backoff.max.ms = 1000 1695658304483, reconnect.backoff.ms = 50 1695658304483, request.timeout.ms = 30000 1695658304483, retries = 2147483647 1695658304483, retry.backoff.ms = 100 1695658304483, sasl.client.callback.handler.class = null 1695658304483, sasl.jaas.config = null 1695658304483, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304483, sasl.kerberos.min.time.before.relogin = 60000 1695658304483, sasl.kerberos.service.name = null 1695658304483, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304483, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304483, sasl.login.callback.handler.class = null 1695658304483, sasl.login.class = null 1695658304483, sasl.login.connect.timeout.ms = null 1695658304483, sasl.login.read.timeout.ms = null 1695658304483, sasl.login.refresh.buffer.seconds = 300 1695658304483, sasl.login.refresh.min.period.seconds = 60 1695658304483, sasl.login.refresh.window.factor = 0.8 1695658304483, sasl.login.refresh.window.jitter = 0.05 1695658304483, sasl.login.retry.backoff.max.ms = 10000 1695658304483, sasl.login.retry.backoff.ms = 100 1695658304483, sasl.mechanism = GSSAPI 1695658304483, sasl.oauthbearer.clock.skew.seconds = 30 1695658304483, sasl.oauthbearer.expected.audience = null 1695658304483, sasl.oauthbearer.expected.issuer = null 1695658304483, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304483, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304483, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304483, sasl.oauthbearer.jwks.endpoint.url = null 1695658304483, sasl.oauthbearer.scope.claim.name = scope 1695658304483, sasl.oauthbearer.sub.claim.name = sub 1695658304483, sasl.oauthbearer.token.endpoint.url = null 1695658304483, security.protocol = PLAINTEXT 1695658304483, security.providers = null 1695658304483, send.buffer.bytes = 131072 1695658304483, socket.connection.setup.timeout.max.ms = 30000 1695658304483, socket.connection.setup.timeout.ms = 10000 1695658304483, ssl.cipher.suites = null 1695658304483," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304483, ssl.endpoint.identification.algorithm = null 1695658304483, ssl.engine.factory.class = null 1695658304483, ssl.key.password = null 1695658304483, ssl.keymanager.algorithm = SunX509 1695658304483, ssl.keystore.certificate.chain = null 1695658304483, ssl.keystore.key = null 1695658304483, ssl.keystore.location = null 1695658304483, ssl.keystore.password = null 1695658304483, ssl.keystore.type = JKS 1695658304483, ssl.protocol = TLSv1.2 1695658304483, ssl.provider = null 1695658304483, ssl.secure.random.implementation = null 1695658304483, ssl.trustmanager.algorithm = PKIX 1695658304483, ssl.truststore.certificates = null 1695658304483, ssl.truststore.location = null 1695658304483, ssl.truststore.password = null 1695658304483, ssl.truststore.type = JKS 1695658304483, transaction.timeout.ms = 60000 1695658304483, transactional.id = null 1695658304483, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304483,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349218] Instantiated an idempotent producer. 1695658304484,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304484,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304484,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304484,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304484 1695658304485,16:11:44 [] [] [] [] INFO AbstractConfig ProducerConfig values: 1695658304485, acks = -1 1695658304485, batch.size = 16384 1695658304485, bootstrap.servers = [kafka.ocp3.folio-eis.us-east-1:9092] 1695658304485, buffer.memory = 33554432 1695658304485, client.dns.lookup = use_all_dns_ips 1695658304485, client.id = producer-349219 1695658304485, compression.type = gzip 1695658304485, connections.max.idle.ms = 540000 1695658304485, delivery.timeout.ms = 120000 1695658304485, enable.idempotence = true 1695658304485, interceptor.classes = [] 1695658304485, key.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304485, linger.ms = 0 1695658304485, max.block.ms = 60000 1695658304485, max.in.flight.requests.per.connection = 5 1695658304485, max.request.size = 4000000 1695658304485, metadata.max.age.ms = 300000 1695658304485, metadata.max.idle.ms = 300000 1695658304485, metric.reporters = [] 1695658304485, metrics.num.samples = 2 1695658304485, metrics.recording.level = INFO 1695658304485, metrics.sample.window.ms = 30000 1695658304485, partitioner.adaptive.partitioning.enable = true 1695658304485, partitioner.availability.timeout.ms = 0 1695658304485, partitioner.class = null 1695658304485, partitioner.ignore.keys = false 1695658304485, receive.buffer.bytes = 32768 1695658304485, reconnect.backoff.max.ms = 1000 1695658304485, reconnect.backoff.ms = 50 1695658304485, request.timeout.ms = 30000 1695658304485, retries = 2147483647 1695658304485, retry.backoff.ms = 100 1695658304485, sasl.client.callback.handler.class = null 1695658304485, sasl.jaas.config = null 1695658304485, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304485, sasl.kerberos.min.time.before.relogin = 60000 1695658304485, sasl.kerberos.service.name = null 1695658304485, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304485, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304485, sasl.login.callback.handler.class = null 1695658304485, sasl.login.class = null 1695658304485, sasl.login.connect.timeout.ms = null 1695658304485, sasl.login.read.timeout.ms = null 1695658304485, sasl.login.refresh.buffer.seconds = 300 1695658304485, sasl.login.refresh.min.period.seconds = 60 1695658304485, sasl.login.refresh.window.factor = 0.8 1695658304485, sasl.login.refresh.window.jitter = 0.05 1695658304485, sasl.login.retry.backoff.max.ms = 10000 1695658304485, sasl.login.retry.backoff.ms = 100 1695658304485, sasl.mechanism = GSSAPI 1695658304485, sasl.oauthbearer.clock.skew.seconds = 30 1695658304485, sasl.oauthbearer.expected.audience = null 1695658304485, sasl.oauthbearer.expected.issuer = null 1695658304485, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304485, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304485, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304485, sasl.oauthbearer.jwks.endpoint.url = null 1695658304485, sasl.oauthbearer.scope.claim.name = scope 1695658304485, sasl.oauthbearer.sub.claim.name = sub 1695658304485, sasl.oauthbearer.token.endpoint.url = null 1695658304485, security.protocol = PLAINTEXT 1695658304485, security.providers = null 1695658304485, send.buffer.bytes = 131072 1695658304485, socket.connection.setup.timeout.max.ms = 30000 1695658304485, socket.connection.setup.timeout.ms = 10000 1695658304485, ssl.cipher.suites = null 1695658304485," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304485, ssl.endpoint.identification.algorithm = null 1695658304485, ssl.engine.factory.class = null 1695658304485, ssl.key.password = null 1695658304485, ssl.keymanager.algorithm = SunX509 1695658304485, ssl.keystore.certificate.chain = null 1695658304485, ssl.keystore.key = null 1695658304485, ssl.keystore.location = null 1695658304485, ssl.keystore.password = null 1695658304485, ssl.keystore.type = JKS 1695658304485, ssl.protocol = TLSv1.2 1695658304485, ssl.provider = null 1695658304485, ssl.secure.random.implementation = null 1695658304485, ssl.trustmanager.algorithm = PKIX 1695658304485, ssl.truststore.certificates = null 1695658304485, ssl.truststore.location = null 1695658304485, ssl.truststore.password = null 1695658304485, ssl.truststore.type = JKS 1695658304485, transaction.timeout.ms = 60000 1695658304485, transactional.id = null 1695658304485, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304485,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349219] Instantiated an idempotent producer. 1695658304485,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349218] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_SRS_MARC_BIB_INSTANCE_HRID_SET-0 to 0 since the associated topicId changed from null to 8DLP8m8dTKKVjEQ7qe1ntw 1695658304485,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349218] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_SRS_MARC_BIB_INSTANCE_HRID_SET-1 to 0 since the associated topicId changed from null to 8DLP8m8dTKKVjEQ7qe1ntw 1695658304485,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349218] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304485,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349218] ProducerId set to 5730646 with epoch 0 1695658304487,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304487,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304487,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304487,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304487 1695658304488,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349219] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_LOG_SRS_MARC_BIB_RECORD_CREATED-0 to 0 since the associated topicId changed from null to 0xneTqT0Ruaxwu0X-1a1mA 1695658304488,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349219] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_LOG_SRS_MARC_BIB_RECORD_CREATED-1 to 0 since the associated topicId changed from null to 0xneTqT0Ruaxwu0X-1a1mA 1695658304488,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349219] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304488,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349219] ProducerId set to 5730647 with epoch 0 1695658304488,16:11:44 [] [] [] [] INFO AbstractConfig ProducerConfig values: 1695658304488, acks = -1 1695658304488, batch.size = 16384 1695658304488, bootstrap.servers = [kafka.ocp3.folio-eis.us-east-1:9092] 1695658304488, buffer.memory = 33554432 1695658304488, client.dns.lookup = use_all_dns_ips 1695658304488, client.id = producer-349220 1695658304488, compression.type = gzip 1695658304488, connections.max.idle.ms = 540000 1695658304488, delivery.timeout.ms = 120000 1695658304488, enable.idempotence = true 1695658304488, interceptor.classes = [] 1695658304488, key.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304488, linger.ms = 0 1695658304488, max.block.ms = 60000 1695658304488, max.in.flight.requests.per.connection = 5 1695658304488, max.request.size = 4000000 1695658304488, metadata.max.age.ms = 300000 1695658304488, metadata.max.idle.ms = 300000 1695658304488, metric.reporters = [] 1695658304488, metrics.num.samples = 2 1695658304488, metrics.recording.level = INFO 1695658304488, metrics.sample.window.ms = 30000 1695658304488, partitioner.adaptive.partitioning.enable = true 1695658304488, partitioner.availability.timeout.ms = 0 1695658304488, partitioner.class = null 1695658304488, partitioner.ignore.keys = false 1695658304488, receive.buffer.bytes = 32768 1695658304488, reconnect.backoff.max.ms = 1000 1695658304488, reconnect.backoff.ms = 50 1695658304488, request.timeout.ms = 30000 1695658304488, retries = 2147483647 1695658304488, retry.backoff.ms = 100 1695658304488, sasl.client.callback.handler.class = null 1695658304488, sasl.jaas.config = null 1695658304488, sasl.kerberos.kinit.cmd = /usr/bin/kinit 1695658304488, sasl.kerberos.min.time.before.relogin = 60000 1695658304488, sasl.kerberos.service.name = null 1695658304488, sasl.kerberos.ticket.renew.jitter = 0.05 1695658304488, sasl.kerberos.ticket.renew.window.factor = 0.8 1695658304488, sasl.login.callback.handler.class = null 1695658304488, sasl.login.class = null 1695658304488, sasl.login.connect.timeout.ms = null 1695658304488, sasl.login.read.timeout.ms = null 1695658304488, sasl.login.refresh.buffer.seconds = 300 1695658304488, sasl.login.refresh.min.period.seconds = 60 1695658304488, sasl.login.refresh.window.factor = 0.8 1695658304488, sasl.login.refresh.window.jitter = 0.05 1695658304488, sasl.login.retry.backoff.max.ms = 10000 1695658304488, sasl.login.retry.backoff.ms = 100 1695658304488, sasl.mechanism = GSSAPI 1695658304488, sasl.oauthbearer.clock.skew.seconds = 30 1695658304488, sasl.oauthbearer.expected.audience = null 1695658304488, sasl.oauthbearer.expected.issuer = null 1695658304488, sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 1695658304488, sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 1695658304488, sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 1695658304488, sasl.oauthbearer.jwks.endpoint.url = null 1695658304488, sasl.oauthbearer.scope.claim.name = scope 1695658304488, sasl.oauthbearer.sub.claim.name = sub 1695658304488, sasl.oauthbearer.token.endpoint.url = null 1695658304488, security.protocol = PLAINTEXT 1695658304488, security.providers = null 1695658304488, send.buffer.bytes = 131072 1695658304488, socket.connection.setup.timeout.max.ms = 30000 1695658304488, socket.connection.setup.timeout.ms = 10000 1695658304488, ssl.cipher.suites = null 1695658304488," ssl.enabled.protocols = [TLSv1.2, TLSv1.3]" 1695658304488, ssl.endpoint.identification.algorithm = null 1695658304488, ssl.engine.factory.class = null 1695658304488, ssl.key.password = null 1695658304488, ssl.keymanager.algorithm = SunX509 1695658304488, ssl.keystore.certificate.chain = null 1695658304488, ssl.keystore.key = null 1695658304488, ssl.keystore.location = null 1695658304488, ssl.keystore.password = null 1695658304488, ssl.keystore.type = JKS 1695658304488, ssl.protocol = TLSv1.2 1695658304488, ssl.provider = null 1695658304488, ssl.secure.random.implementation = null 1695658304488, ssl.trustmanager.algorithm = PKIX 1695658304488, ssl.truststore.certificates = null 1695658304488, ssl.truststore.location = null 1695658304488, ssl.truststore.password = null 1695658304488, ssl.truststore.type = JKS 1695658304488, transaction.timeout.ms = 60000 1695658304488, transactional.id = null 1695658304488, value.serializer = class org.apache.kafka.common.serialization.StringSerializer 1695658304488,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349220] Instantiated an idempotent producer. 1695658304489,"16:11:44 [] [] [] [] WARN AbstractConfig These configurations '[ssl.protocol, ssl.keystore.location, ssl.truststore.type, ssl.keystore.type, ssl.truststore.location, ssl.keystore.password, ssl.key.password, ssl.truststore.password, ssl.endpoint.identification.algorithm]' were supplied but are not used yet." 1695658304489,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka version: 3.3.2 1695658304489,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka commitId: b66af662e61082cb 1695658304489,16:11:44 [] [] [] [] INFO ppInfoParser$AppInfo Kafka startTimeMs: 1695658304489 1695658304490,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349220] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED-0 to 0 since the associated topicId changed from null to P6a0F0W6Qvud_iblaEnzRg 1695658304490,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349220] Resetting the last seen epoch of partition ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED-1 to 0 since the associated topicId changed from null to P6a0F0W6Qvud_iblaEnzRg 1695658304490,16:11:44 [] [] [] [] INFO Metadata [Producer clientId=producer-349220] Cluster ID: 0TVOovrbROKzqZMXExsoVQ 1695658304490,16:11:44 [] [] [] [] INFO TransactionManager [Producer clientId=producer-349220] ProducerId set to 5730648 with epoch 0 1695658304495,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 4 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_HOLDING_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_HOLDING_CREATED) Committed offset: 260026" 1695658304495,"16:11:44 [] [] [] [] INFO KafkaConsumerWrapper businessHandlerCompletionHandler:: Consumer - id: 4 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_HOLDING_CREATED, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_HOLDING_CREATED) Committed offset: 260027" 1695658304495,16:11:44 [] [] [] [] INFO KafkaEventPublisher publish:: Event with type: 'DI_ERROR' by jobExecutionId: 'd1e3edb6-0062-49c2-bbbe-9e49fd930479' and recordId: '50c0271d-7252-4ac8-a211-55d273919cdb' with chunkId: '00d1100b-3726-4a94-bf4d-e719d117d7df' was sent to the topic 'ocp3.Default.fs09000000.DI_ERROR' 1695658304496,"16:11:44 [] [] [] [] ERROR KafkaConsumerWrapper businessHandlerCompletionHandler:: Error while processing a record - id: 7 subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING) offset: 249413" 1695658304496,io.vertx.core.impl.NoStackTraceThrowable: handle:: Failed to process data import event payload from topic 'ocp3.Default.fs09000000.DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING' by jobExecutionId: 'd1e3edb6-0062-49c2-bbbe-9e49fd930479' with recordId: '50c0271d-7252-4ac8-a211-55d273919cdb' and chunkId: '00d1100b-3726-4a94-bf4d-e719d117d7df' 1695658304496,"16:11:44 [] [] [] [] WARN KafkaConsumerWrapper businessHandlerCompletionHandler:: Error handler has not been implemented for subscriptionPattern: SubscriptionDefinition(eventType=DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING, subscriptionPattern=ocp3\.Default\.\w{1,}\.DI_INVENTORY_INSTANCE_CREATED_READY_FOR_POST_PROCESSING) failures" 1695658304496,16:11:44 [] [] [] [] INFO KafkaProducer [Producer clientId=producer-349217] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. 1695658304496,16:11:44 [] [] [] [] INFO Metrics Metrics scheduler closed 1695658304496,16:11:44 [] [] [] [] INFO Metrics Closing reporter org.apache.kafka.common.metrics.JmxReporter