[2024-03-09 00:16:26,996] INFO [Worker clientId=connect-1, groupId=cdc] Starting connectors and tasks using config offset 16 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2024-03-09 00:16:26,996] INFO [Worker clientId=connect-1, groupId=cdc] Starting task p1505d-debezium-202403090016-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2024-03-09 00:16:27,001] INFO [p1505d-debezium-202403090016|task-0] Creating task p1505d-debezium-202403090016-0 (org.apache.kafka.connect.runtime.Worker) [2024-03-09 00:16:27,259] INFO [p1505d-debezium-202403090016|task-0] Kafka version: 7.5.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,259] INFO [p1505d-debezium-202403090016|task-0] Kafka commitId: ff3c201baa948d97889dc26c99d7cdc23d038f2e (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,259] INFO [p1505d-debezium-202403090016|task-0] Kafka startTimeMs: 1709943387259 (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,269] INFO [Worker clientId=connect-1, groupId=cdc] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2024-03-09 00:16:27,283] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=connector-producer-p1505d-debezium-202403090016-0] Cluster ID: AoDsD_3kS3SwtizjVg0nEg (org.apache.kafka.clients.Metadata) [2024-03-09 00:16:27,300] INFO [p1505d-debezium-202403090016|task-0] Starting MySqlConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] connector.class = io.debezium.connector.mysql.MySqlConnector (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] snapshot.locking.mode = minimal_percona (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.consumer.sasl.jaas.config = ******** (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.retention.bytes = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.retention.ms = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.kafka.recovery.attempts = 10 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] transforms.AddPrefix.replacement = __debezium_schema_change_$0 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.partitions = 1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.producer.security.protocol = SASL_SSL (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] transforms.AddSnapshotModeToValue.static.field = snapshot_mode (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] converters = boolean (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.producer.sasl.mechanism = SCRAM-SHA-512 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.m_topics.partitions = 4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.m_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.producer.buffer.memory = 33554432 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.s_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] boolean.type = io.debezium.connector.mysql.converters.TinyIntOneToBooleanConverter (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.kafka.bootstrap.servers = (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.include = __debezium_schema_change_p1505d (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.groups = p1505d_schema_change,s_topics,m_topics,l_topics,xl_topics,xxl_topics,xxxl_topics,l_messages (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] producer.override.max.request.size = 10485760 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_topics.partitions = 8 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] table.exclude.list = property_.*\.dates,property_.*\.metadata_[0-9]*_.*,property_.*\..*jerry.*,property_.*\.temp_t,property_.*\.tmp_txns,property_cpm.ids,login_.*\.groups_roles,login_.*\.groups_sites,login_.*\.groups_users,property_.*\..*foo.*,insights_.*\.unit_status_counts.*,property_.*\.reports_base_and_joinable_reports,oportal_.*\.job_states,tportal_.*\.job_states,property_.*\.deets,entitlements_.*\.entitlements_groups,entitlements_.*\.entitlements_tiers,entitlements_.*\.add_ons_groups,entitlements_.*\.groups_tiers,oportal_.*\.af_aci_overrides_maintenance_mode,property_.*\.af_aci_overrides_maintenance_mode,tportal_.*\.af_aci_overrides_maintenance_mode (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] database.exclude.list = (^((?!.+_.+).)*$),(^.*_[a-f0-9]{40}$),.*_aaaaa.*,foo_jerry,merged_.*,.*p1505d.*,^mcccomm_.*test.* (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] max.batch.size = 50000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] snapshot.mode = schema_only (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.consumer.security.protocol = SASL_SSL (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_topics.include = [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] snapshot.delay.ms = 300000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.partitions = 1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.kafka.topic = __debezium_internal_schema_history_p1505d (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] transforms.AddPrefix.regex = p1505d (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] topic.creation.m_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,301] INFO [p1505d-debezium-202403090016|task-0] producer.override.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.type = io.debezium.transforms.ByLogicalTableRouter (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.max_block_ms = 60000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.server.id = (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxl_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.max.compaction.lag.ms = 1209600000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddSnapshotModeToValue.static.value = schema_only (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddDataSourceToKey.static.value = p1505d (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xl_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xl_topics.include = apm.db.property.check_run_details,apm.db.property.guest_card_activities,apm.db.adep.task_outputs,apm.db.property.maintenance_work_order_activities,apm.db.property.temporary_objects,apm.db.property.contact_info_versions,apm.db.property.contact_infos,apm.db.property.emails,apm.db.property.phone_numbers,apm.db.property.guest_card_interests,apm.db.property.prospects,apm.db.property.guest_card_details,apm.db.property.dividend_payment_histories,apm.db.property.leads_communication_histories,apm.db.property.core_versions,apm.db.insights.cash_day_balances,apm.db.reports.job_states,apm.db.property.accrual_basis_year_balances,apm.db.property.cash_basis_year_balances,apm.db.insights.af_parallel_job_parallel_job_chunks,apm.db.insights.work_order_status_changes,apm.db.property.txn_batches,apm.db.ops.vhosts (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.kafka.recovery.poll.interval.ms = 3600000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxxl_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] task.class = io.debezium.connector.mysql.MySqlConnectorTask (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.connectionTimeZone = UTC (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.key.field.regex = (.*)\.(.*)_(.*)\.(.*) (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.buffer.memory = 409600000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxl_topics.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxl_topics.partitions = 32 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] column.truncate.to.524288.chars = oportal_.*\.versions\.object,oportal_.*\.versions\.object_changes (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.partitions = 1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.key.field.name = vhost (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms = Reroute,AddPrefix,AddDataSourceToKey,AddSnapshotModeToValue (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.linger.ms = 100 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.cleanup.policy = delete (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.topic.replacement = apm.db.$2.$4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.delete.retention.ms = 1209600000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.s_topics.partitions = 2 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.user = (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.compression.type = lz4 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxxl_topics.partitions = 64 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.s_topics.include = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.topic.regex = (.*)\.(.*)_(.*)\.(.*) (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddDataSourceToKey.static.field = __datasource! (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.m_topics.include = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.password = ******** (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.min.compaction.lag.ms = 1209600000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.max.message.bytes = 10000000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] name = p1505d-debezium-202403090016 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.producer.sasl.jaas.config = ******** (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] schema.history.internal.consumer.sasl.mechanism = SCRAM-SHA-512 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_topics.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] max.queue.size = 200000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddPrefix.type = org.apache.kafka.connect.transforms.RegexRouter (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xl_topics.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.batch.size = 200000 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.l_messages.include = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxl_topics.include = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.prefix = p1505d (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.s_topics.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] include.schema.comments = true (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.acks = all (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxl_topics.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxxl_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddDataSourceToKey.type = org.apache.kafka.connect.transforms.InsertField$Key (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxxl_topics.include = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xxxl_topics.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.default.cleanup.policy = compact (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.p1505d_schema_change.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.s_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.port = 3306 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.AddSnapshotModeToValue.type = org.apache.kafka.connect.transforms.InsertField$Value (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.enabled = true (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] transforms.Reroute.key.field.replacement = $3 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] column.exclude.list = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] column.truncate.to.1048576.chars = [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xl_topics.replication.factor = -1 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] database.hostname = (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] producer.override.max.in.flight.requests.per.connection = 5 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,302] INFO [p1505d-debezium-202403090016|task-0] topic.creation.xl_topics.partitions = 16 (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,308] INFO [p1505d-debezium-202403090016|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mysql.MySqlSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [2024-03-09 00:16:27,326] INFO [p1505d-debezium-202403090016|task-0] Using io.debezium.connector.mysql.strategy.mysql.MySqlConnectorAdapter (io.debezium.connector.mysql.MySqlConnectorConfig) [2024-03-09 00:16:27,329] INFO [p1505d-debezium-202403090016|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [2024-03-09 00:16:27,349] INFO [p1505d-debezium-202403090016|task-0] No previous offsets found (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,584] INFO [p1505d-debezium-202403090016|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=p1505d-schemahistory, bootstrap.servers=, security.protocol=SASL_SSL, enable.auto.commit=false, sasl.mechanism=SCRAM-SHA-512, sasl.jaas.config=********, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=p1505d-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory) [2024-03-09 00:16:27,584] INFO [p1505d-debezium-202403090016|task-0] KafkaSchemaHistory Producer config: {batch.size=32768, acks=1, bootstrap.servers=, buffer.memory=33554432, key.serializer=org.apache.kafka.common.serialization.StringSerializer, security.protocol=SASL_SSL, retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, sasl.mechanism=SCRAM-SHA-512, sasl.jaas.config=********, max.block.ms=10000, client.id=p1505d-schemahistory, linger.ms=0} (io.debezium.storage.kafka.history.KafkaSchemaHistory) [2024-03-09 00:16:27,585] INFO [p1505d-debezium-202403090016|task-0] Requested thread factory for connector MySqlConnector, id = p1505d named = db-history-config-check (io.debezium.util.Threads) [2024-03-09 00:16:27,587] INFO [p1505d-debezium-202403090016|task-0] Idempotence will be disabled because acks is set to 1, not set to 'all'. (org.apache.kafka.clients.producer.ProducerConfig) [2024-03-09 00:16:27,587] INFO [p1505d-debezium-202403090016|task-0] ProducerConfig values: acks = 1 auto.include.jmx.reporter = true batch.size = 32768 bootstrap.servers = buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = p1505d-schemahistory compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 10000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = SCRAM-SHA-512 sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.StringSerializer (org.apache.kafka.clients.producer.ProducerConfig) [2024-03-09 00:16:27,589] INFO [p1505d-debezium-202403090016|task-0] Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [2024-03-09 00:16:27,590] INFO [p1505d-debezium-202403090016|task-0] Kafka version: 7.5.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,590] INFO [p1505d-debezium-202403090016|task-0] Kafka commitId: ff3c201baa948d97889dc26c99d7cdc23d038f2e (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,590] INFO [p1505d-debezium-202403090016|task-0] Kafka startTimeMs: 1709943387590 (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,626] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=p1505d-schemahistory] Cluster ID: AoDsD_3kS3SwtizjVg0nEg (org.apache.kafka.clients.Metadata) [2024-03-09 00:16:27,636] INFO [p1505d-debezium-202403090016|task-0] Checking all known binlogs from the database (io.debezium.connector.mysql.strategy.AbstractConnectorConnection) [2024-03-09 00:16:27,637] WARN [p1505d-debezium-202403090016|task-0] It is possible the server has purged some binlogs. If this is the case, then using snapshot mode may be required. (io.debezium.connector.mysql.MySqlConnectorTask) [2024-03-09 00:16:27,638] INFO [p1505d-debezium-202403090016|task-0] Closing connection before starting schema recovery (io.debezium.connector.mysql.MySqlConnectorTask) [2024-03-09 00:16:27,640] INFO [p1505d-debezium-202403090016|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2024-03-09 00:16:27,640] INFO [p1505d-debezium-202403090016|task-0] Connector started for the first time. (io.debezium.connector.common.BaseSourceTask) [2024-03-09 00:16:27,641] INFO [p1505d-debezium-202403090016|task-0] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = check.crcs = true client.dns.lookup = use_all_dns_ips client.id = p1505d-schemahistory client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = p1505d-schemahistory group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = SCRAM-SHA-512 sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [2024-03-09 00:16:27,643] INFO [p1505d-debezium-202403090016|task-0] Kafka version: 7.5.0-ccs (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,643] INFO [p1505d-debezium-202403090016|task-0] Kafka commitId: ff3c201baa948d97889dc26c99d7cdc23d038f2e (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,643] INFO [p1505d-debezium-202403090016|task-0] Kafka startTimeMs: 1709943387643 (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,668] INFO [p1505d-debezium-202403090016|task-0] [Consumer clientId=p1505d-schemahistory, groupId=p1505d-schemahistory] Cluster ID: AoDsD_3kS3SwtizjVg0nEg (org.apache.kafka.clients.Metadata) [2024-03-09 00:16:27,670] INFO [p1505d-debezium-202403090016|task-0] [Consumer clientId=p1505d-schemahistory, groupId=p1505d-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2024-03-09 00:16:27,670] INFO [p1505d-debezium-202403090016|task-0] [Consumer clientId=p1505d-schemahistory, groupId=p1505d-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [2024-03-09 00:16:27,671] INFO [p1505d-debezium-202403090016|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 00:16:27,671] INFO [p1505d-debezium-202403090016|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2024-03-09 00:16:27,671] INFO [p1505d-debezium-202403090016|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 00:16:27,672] INFO [p1505d-debezium-202403090016|task-0] App info kafka.consumer for p1505d-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 00:16:27,672] INFO [p1505d-debezium-202403090016|task-0] Reconnecting after finishing schema recovery (io.debezium.connector.mysql.MySqlConnectorTask) [2024-03-09 00:16:27,689] INFO [p1505d-debezium-202403090016|task-0] No previous offset found (io.debezium.connector.mysql.MySqlConnectorTask) [2024-03-09 00:16:27,708] INFO [p1505d-debezium-202403090016|task-0] Requested thread factory for connector MySqlConnector, id = p1505d named = SignalProcessor (io.debezium.util.Threads) [2024-03-09 00:16:27,723] INFO [p1505d-debezium-202403090016|task-0] Requested thread factory for connector MySqlConnector, id = p1505d named = change-event-source-coordinator (io.debezium.util.Threads) [2024-03-09 00:16:27,723] INFO [p1505d-debezium-202403090016|task-0] Requested thread factory for connector MySqlConnector, id = p1505d named = blocking-snapshot (io.debezium.util.Threads) [2024-03-09 00:16:27,725] INFO [p1505d-debezium-202403090016|task-0] Creating thread debezium-mysqlconnector-p1505d-change-event-source-coordinator (io.debezium.util.Threads) [2024-03-09 00:16:27,725] INFO [p1505d-debezium-202403090016|task-0] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [2024-03-09 00:16:27,727] INFO [p1505d-debezium-202403090016|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-03-09 00:16:27,728] INFO [p1505d-debezium-202403090016|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-03-09 00:16:27,734] INFO [p1505d-debezium-202403090016|task-0] According to the connector configuration only schema will be snapshotted (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 00:16:27,735] INFO [p1505d-debezium-202403090016|task-0] The connector will wait for 300s before proceeding (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [2024-03-09 00:18:32,735] INFO [p1505d-debezium-202403090016|task-0] The connector will wait for 175s before proceeding (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [2024-03-09 00:21:22,735] INFO [p1505d-debezium-202403090016|task-0] The connector will wait for 5s before proceeding (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [2024-03-09 00:21:32,737] INFO [p1505d-debezium-202403090016|task-0] Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 00:21:32,739] INFO [p1505d-debezium-202403090016|task-0] Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 00:21:32,739] INFO [p1505d-debezium-202403090016|task-0] Read list of available databases (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 00:21:32,825] INFO [p1505d-debezium-202403090016|task-0] Read list of available tables in each database (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 00:28:20,282] INFO [p1505d-debezium-202403090016|task-0] \tsnapshot continuing with database(s): [600 database names have been hidden] [2024-03-09 00:28:20,426] INFO [p1505d-debezium-202403090016|task-0] Adding table db1.t1 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource) ... [2024-03-09 00:28:21,159] INFO [p1505d-debezium-202403090016|task-0] Adding table db600.t700000 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 00:29:10,224] INFO [p1505d-debezium-202403090016|task-0] Reading structure of database 'db1' (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) ... [2024-03-09 01:06:18,455] INFO [p1505d-debezium-202403090016|task-0] Reading structure of database 'db400' (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 00:32:44,018] WARN [p1505d-debezium-202403090016|task-0] Skip to set unique index columns [id INT(11) DEFAULT VALUE NULL] to primary key which including optional columns (io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser) ... [2024-03-09 01:18:57,926] INFO [p1505d-debezium-202403090016|task-0] Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 01:18:57,961] INFO [p1505d-debezium-202403090016|task-0] Already applied 1 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:18:58,292] INFO [p1505d-debezium-202403090016|task-0] 253 records sent during previous 01:02:31.28, last recorded offset of {server=p1505d} partition is {ts_sec=1709944147, file=binlog.000888, pos=58731377, gtids=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, snapshot=true} (io.debezium.connector.common.BaseSourceTask) [2024-03-09 01:18:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1647 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:01,592] INFO [p1505d-debezium-202403090016|task-0] Already applied 4509 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 7700 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 11134 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:07,380] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 13142 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask)[2024-03-09 01:18:57,593] INFO [p1505d-debezium-202403090016|task-0] Reading structure of database 'tportal_zedgroup' (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 01:18:57,926] INFO [p1505d-debezium-202403090016|task-0] Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 01:18:57,961] INFO [p1505d-debezium-202403090016|task-0] Already applied 1 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:18:58,292] INFO [p1505d-debezium-202403090016|task-0] 253 records sent during previous 01:02:31.28, last recorded offset of {server=p1505d} partition is {ts_sec=1709944147, file=binlog.000888, pos=58731377, gtids=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, snapshot=true} (io.debezium.connector.common.BaseSourceTask) [2024-03-09 01:18:58,460] INFO [p1505d-debezium-202403090016|task-0] The task will send records to topic '__debezium_schema_change_p1505d' for the first time. Checking whether topic exists (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [2024-03-09 01:18:58,463] INFO [p1505d-debezium-202403090016|task-0] Topic '__debezium_schema_change_p1505d' already exists. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [2024-03-09 01:18:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1647 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:01,592] INFO [p1505d-debezium-202403090016|task-0] Already applied 4509 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 7700 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 11134 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:07,380] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 13142 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 14146 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 17414 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 20914 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 24286 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 27643 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:17,526] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16704 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 30922 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 33968 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 37299 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 40778 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 43864 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 47186 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:27,628] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16375 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 50593 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 53951 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 57230 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 60573 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 64134 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:37,730] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17220 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 67652 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 70972 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 74103 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 77594 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 81097 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:47,832] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16747 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 84610 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 87990 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 91335 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 94859 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 98396 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:19:57,934] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17984 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:19:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 101910 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 105311 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:02,317] INFO 10.122.13.251 - - [09/Mar/2024:01:20:02 +0000] "GET /connectors/p1505d-debezium-202403090016/status HTTP/1.1" 200 188 "-" "python-requests/2.31.0" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [2024-03-09 01:20:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 108790 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 112212 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 115760 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:08,037] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17611 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 119304 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 122801 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 126292 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 129734 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 133296 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:18,139] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17778 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 136713 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 140171 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 143646 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 146948 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:27,593] INFO [p1505d-debezium-202403090016|task-0] Already applied 150598 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:28,241] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17424 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 154167 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 157715 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 161121 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 164520 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 168048 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:38,344] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17663 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 171560 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 175211 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 178611 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 182191 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 185738 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:48,446] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 18017 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 189282 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 192842 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 196330 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 199811 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 203349 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:20:58,549] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17742 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:20:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 206901 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 210403 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 213969 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 217519 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 221088 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:08,651] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 18014 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 224586 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 228126 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 231695 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 235184 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 238766 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:18,753] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17849 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 242095 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 245583 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 248991 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 252516 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 256032 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:28,856] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17455 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 259530 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 263164 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 266631 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 270120 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 273622 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:38,958] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17800 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 277104 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 280626 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:41,776] INFO [Worker clientId=connect-1, groupId=cdc] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [2024-03-09 01:21:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 284025 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 287582 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 291062 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:49,060] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17725 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 294587 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 298101 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 301476 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 304992 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 308554 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:21:59,162] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17692 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:21:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 312084 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 315516 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 318957 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 322500 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 325889 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:09,264] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17436 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:22:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 329375 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 332953 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 336398 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 339935 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 343250 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:19,367] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17537 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:22:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 346678 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 350158 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 353668 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 357131 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 360587 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:29,469] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17426 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:22:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 364159 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 367682 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 371106 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 374510 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 378104 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:39,571] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17742 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:22:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 381640 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:41,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 385167 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 388640 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:45,585] INFO [p1505d-debezium-202403090016|task-0] Already applied 392191 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 395580 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 399099 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:49,674] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17774 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:22:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 402579 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 405989 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 409486 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 413057 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 416286 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:22:59,776] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17351 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 419852 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:03,594] INFO [p1505d-debezium-202403090016|task-0] Already applied 423365 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 426747 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 430301 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 433715 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:09,878] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17687 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 437239 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 440730 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 444353 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 447757 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 451269 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:19,980] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17074 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 454592 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 458093 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 461373 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 464793 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 468278 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:30,100] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17636 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 471621 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 475219 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 478608 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 482047 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 485472 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:40,202] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17468 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 488918 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 492192 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 495682 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 499179 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:48,411] INFO [AdminClient clientId=cdc--shared-admin] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:23:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 502356 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:50,304] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16428 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:23:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 505675 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 509244 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 512796 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 516173 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:23:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 519517 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:00,406] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17340 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 522949 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:03,605] INFO [p1505d-debezium-202403090016|task-0] Already applied 526262 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 529732 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 533312 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 536950 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:10,508] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17610 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 540528 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:13,600] INFO [p1505d-debezium-202403090016|task-0] Already applied 544054 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 547576 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 551076 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 554365 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:20,611] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17544 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 557831 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:23,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 561155 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 564558 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:27,595] INFO [p1505d-debezium-202403090016|task-0] Already applied 568033 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 571588 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:30,713] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17796 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 575157 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 578633 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 582188 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 585448 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 588795 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:40,815] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17383 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 592131 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 595310 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 598856 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 602384 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 605826 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:50,917] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17323 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:24:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 609366 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 612951 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 616564 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 620060 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:24:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 623668 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:01,020] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 18096 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 627212 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 630643 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 633790 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 636871 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 640101 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:11,122] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16507 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 643372 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 646655 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 650176 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 653118 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 656146 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:21,224] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16276 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 659325 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 662870 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 665875 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 669467 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 672767 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:31,357] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16887 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 676261 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 679440 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 682750 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 686103 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 689314 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:41,459] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16422 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 692612 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 696126 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 699395 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 702733 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 706081 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:51,561] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17181 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:25:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 709599 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:53,588] INFO [p1505d-debezium-202403090016|task-0] Already applied 712983 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:55,595] INFO [p1505d-debezium-202403090016|task-0] Already applied 716383 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 719831 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:25:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 723010 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 726419 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:01,664] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17223 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 729877 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 733379 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:07,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 736906 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 740348 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 743634 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:11,766] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17335 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 747020 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 750533 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 753928 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 757258 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 760732 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:21,868] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17326 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 764166 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 767163 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 770550 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:28,727] INFO [p1505d-debezium-202403090016|task-0] [AdminClient clientId=connector-adminclient-p1505d-debezium-202403090016-0] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:26:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 773909 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 777298 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:31,975] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 15794 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 780596 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 783974 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 787320 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 790617 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:41,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 793790 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:42,077] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16514 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 797291 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 800653 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 804142 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 807483 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:51,592] INFO [p1505d-debezium-202403090016|task-0] Already applied 810762 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:52,180] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17620 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:26:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 814046 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 817568 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 821092 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:26:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 824260 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 827808 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:02,282] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17156 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 831143 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 834341 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 837405 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 840793 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 844370 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:12,384] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16956 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 847949 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 851355 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 854651 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 857702 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 861144 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:22,485] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17030 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 864468 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 867812 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 871228 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 874417 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 877634 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:32,588] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16542 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 880929 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 884349 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:37,654] INFO [p1505d-debezium-202403090016|task-0] Already applied 887828 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:39,605] INFO [p1505d-debezium-202403090016|task-0] Already applied 890952 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:41,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 894410 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:42,695] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16752 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 897559 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 900827 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 904182 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 907398 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 910834 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:52,797] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17112 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:27:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 914271 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 917516 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 920644 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:27:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 924050 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 927433 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:02,563] INFO 10.122.13.251 - - [09/Mar/2024:01:28:02 +0000] "GET /connectors/p1505d-debezium-202403090016/status HTTP/1.1" 200 188 "-" "python-requests/2.31.0" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [2024-03-09 01:28:02,900] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16698 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 931012 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 934238 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 937812 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 941164 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 944439 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:13,002] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16389 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:13,002] INFO [Producer clientId=cdc--offsets] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:28:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 947860 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 951216 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 954750 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:18,117] INFO [Producer clientId=cdc--statuses] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:28:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 958149 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 961502 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:23,104] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17707 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 964680 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 967947 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 971421 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 974873 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 978264 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:33,206] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17494 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 981840 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 985120 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 988452 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 991793 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 995279 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:43,309] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17169 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 998630 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1002137 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1005485 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:48,479] INFO [AdminClient clientId=cdc--shared-admin] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:28:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1008753 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:51,585] INFO [p1505d-debezium-202403090016|task-0] Already applied 1011975 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:53,411] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16864 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:28:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1015379 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1018752 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1022088 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:28:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1025492 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1028865 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:03,513] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16280 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1032117 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1035371 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1038923 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1042439 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1045771 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:13,603] INFO [p1505d-debezium-202403090016|task-0] Already applied 1049292 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:13,616] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17219 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1052543 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:17,584] INFO [p1505d-debezium-202403090016|task-0] Already applied 1055934 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1059119 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1062661 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1065867 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:23,718] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17067 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1069316 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1072798 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:28,088] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=connector-producer-p1505d-debezium-202403090016-0] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:29:28,116] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=p1505d-schemahistory] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:29:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1076085 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1079324 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1082799 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:33,820] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17048 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1086210 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1089512 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1092994 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1096375 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1099697 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:43,922] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17143 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1102893 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1106396 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1109877 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1113266 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1116774 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:54,024] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17293 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:29:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1120180 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1123392 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:29:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1126758 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1130214 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:02,674] INFO 10.122.13.251 - - [09/Mar/2024:01:30:02 +0000] "GET /connectors/p1505d-debezium-202403090016/status HTTP/1.1" 200 188 "-" "python-requests/2.31.0" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [2024-03-09 01:30:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1133655 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:04,127] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17096 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1136982 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1140370 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1143674 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1147026 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1150343 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:14,229] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16967 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1153606 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1156982 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1160276 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1163802 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1167050 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:24,331] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17081 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1170245 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1173601 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1177094 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1180420 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1183804 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:34,433] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16267 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:35,592] INFO [p1505d-debezium-202403090016|task-0] Already applied 1187125 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1190315 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1193559 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1197053 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1200471 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:44,536] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17570 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1203778 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:47,619] INFO [p1505d-debezium-202403090016|task-0] Already applied 1207198 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1210661 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1213962 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1217057 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:54,638] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16878 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:30:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1220603 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:57,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1224012 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:30:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1227409 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1230915 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1234309 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:04,740] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16637 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1237529 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1240873 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1244346 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1247640 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1251120 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:14,843] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17121 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1254586 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1258079 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1260996 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1264369 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1267736 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:24,945] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16882 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1271175 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1274436 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:28,828] INFO [p1505d-debezium-202403090016|task-0] [AdminClient clientId=connector-adminclient-p1505d-debezium-202403090016-0] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) [2024-03-09 01:31:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1277901 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1281350 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1284544 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:35,047] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16532 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1287727 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:37,587] INFO [p1505d-debezium-202403090016|task-0] Already applied 1291054 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1294503 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1298009 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1301501 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:45,149] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 18002 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1304979 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1308163 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:49,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1311480 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1314841 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1318365 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:55,251] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16948 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:31:55,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1321865 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:57,585] INFO [p1505d-debezium-202403090016|task-0] Already applied 1325215 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:31:59,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1328604 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:01,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1331743 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:02,781] INFO 10.122.13.251 - - [09/Mar/2024:01:32:02 +0000] "GET /connectors HTTP/1.1" 200 32 "-" "python-requests/2.31.0" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [2024-03-09 01:32:03,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1335124 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:05,359] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16230 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:32:05,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1338634 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:07,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1342216 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:09,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1345437 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:11,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1349036 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:13,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1352337 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:15,461] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17746 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:32:15,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1355649 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:17,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1358930 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:19,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1362157 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:21,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1365697 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:23,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1368977 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:25,563] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16990 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:32:25,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1372396 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:27,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1375706 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:29,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1378998 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:31,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1382334 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:33,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1385882 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:35,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1389285 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:35,665] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17010 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:32:37,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1392709 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:39,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1396134 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:41,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1399515 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:43,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1402843 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:45,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1406212 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:45,768] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 17217 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:32:47,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1409806 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:49,620] INFO [p1505d-debezium-202403090016|task-0] Already applied 1413197 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:51,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1416648 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:53,583] INFO [p1505d-debezium-202403090016|task-0] Already applied 1420165 database changes (io.debezium.relational.history.SchemaHistoryMetrics) [2024-03-09 01:32:55,870] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 16261 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:33:13,408] INFO [p1505d-debezium-202403090016|task-0] Releasing global read lock to enable MySQL writes (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 01:33:13,409] INFO [p1505d-debezium-202403090016|task-0] Writes to MySQL tables prevented for a total of 01:04:40.057 (io.debezium.connector.mysql.MySqlSnapshotChangeEventSource) [2024-03-09 01:33:13,409] INFO [p1505d-debezium-202403090016|task-0] Snapshot step 7 - Skipping snapshotting of data (io.debezium.relational.RelationalSnapshotChangeEventSource) [2024-03-09 01:33:13,411] INFO [p1505d-debezium-202403090016|task-0] Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [2024-03-09 01:33:13,411] INFO [p1505d-debezium-202403090016|task-0] Snapshot completed (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [2024-03-09 01:33:13,445] INFO [p1505d-debezium-202403090016|task-0] Snapshot ended with SnapshotResult [status=COMPLETED, offset=MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=binlog.000888, currentBinlogPosition=58731377, currentRowNumber=0, serverId=0, sourceTime=2024-03-09T01:32:54.714Z, threadId=-1, currentQuery=null, tableIds=[property_covenanthoa.wego_bills_oauth_tokens], databaseName=tportal_zedgroup], snapshotCompleted=true, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, currentGtidSet=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, restartBinlogFilename=binlog.000888, restartBinlogPosition=58731377, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-03-09 01:33:15,972] INFO [p1505d-debezium-202403090016|task-0|offsets] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Committing offsets for 1 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask) [2024-03-09 01:33:22,302] INFO [p1505d-debezium-202403090016|task-0] Requested thread factory for connector MySqlConnector, id = p1505d named = binlog-client (io.debezium.util.Threads) [2024-03-09 01:33:22,309] INFO [p1505d-debezium-202403090016|task-0] Enable ssl PREFERRED mode for connector p1505d (io.debezium.connector.mysql.strategy.AbstractBinaryLogClientConfigurator) [2024-03-09 01:33:22,318] INFO [p1505d-debezium-202403090016|task-0] SignalProcessor started. Scheduling it every 5000ms (io.debezium.pipeline.signal.SignalProcessor) [2024-03-09 01:33:22,318] INFO [p1505d-debezium-202403090016|task-0] Creating thread debezium-mysqlconnector-p1505d-SignalProcessor (io.debezium.util.Threads) [2024-03-09 01:33:22,318] INFO [p1505d-debezium-202403090016|task-0] Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] GTID set purged on server: '6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-427721837,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898' (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] Attempting to generate a filtered GTID set (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] GTID set from previous recorded offset: 6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898 (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] GTID set available on server: 6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431835105,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898 (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] Using first available positions for new GTID channels (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,889] INFO [p1505d-debezium-202403090016|task-0] Relevant GTID set available on server: 6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431835105,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898 (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,890] INFO [p1505d-debezium-202403090016|task-0] Final merged GTID set to use when connecting to MySQL: 6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898 (io.debezium.connector.mysql.strategy.mysql.MySqlConnection) [2024-03-09 01:33:30,890] INFO [p1505d-debezium-202403090016|task-0] Registering binlog reader with GTID set: '6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898' (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,891] INFO [p1505d-debezium-202403090016|task-0] Skip 0 events on streaming start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,891] INFO [p1505d-debezium-202403090016|task-0] Skip 0 rows on streaming start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,891] INFO [p1505d-debezium-202403090016|task-0] Creating thread debezium-mysqlconnector-p1505d-binlog-client (io.debezium.util.Threads) [2024-03-09 01:33:30,900] INFO [p1505d-debezium-202403090016|task-0] Creating thread debezium-mysqlconnector-p1505d-binlog-client (io.debezium.util.Threads) Mar 09, 2024 1:33:30 AM com.github.shyiko.mysql.binlog.BinaryLogClient tryUpgradeToSSL INFO: SSL enabled Mar 09, 2024 1:33:30 AM com.github.shyiko.mysql.binlog.BinaryLogClient connect INFO: Connected to p1505db-d-backup.awssl.appfolio.net:3306 at 6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898 (sid:8015051000, cid:3871531) [2024-03-09 01:33:30,968] INFO [p1505d-debezium-202403090016|task-0] Connected to binlog at p1505db-d-backup.awssl.appfolio.net:3306, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=binlog.000888, currentBinlogPosition=58731377, currentRowNumber=0, serverId=0, sourceTime=2024-03-09T01:32:54.714Z, threadId=-1, currentQuery=null, tableIds=[property_covenanthoa.wego_bills_oauth_tokens], databaseName=tportal_zedgroup], snapshotCompleted=true, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, currentGtidSet=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, restartBinlogFilename=binlog.000888, restartBinlogPosition=58731377, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]] (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,968] INFO [p1505d-debezium-202403090016|task-0] Waiting for keepalive thread to start (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:30,968] INFO [p1505d-debezium-202403090016|task-0] Creating thread debezium-mysqlconnector-p1505d-binlog-client (io.debezium.util.Threads) [2024-03-09 01:33:31,068] INFO [p1505d-debezium-202403090016|task-0] Keepalive thread is running (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:31,187] ERROR [p1505d-debezium-202403090016|task-0] Encountered change event 'Event{header=EventHeaderV4{timestamp=1709944115000, eventType=TABLE_MAP, serverId=175348621, headerLength=19, dataLength=64, nextPosition=58731588, flags=0}, data=TableMapEventData{tableId=921653496, database='property_pureprop', table='notes', columnTypes=3, 15, -4, 18, 18, 3, 15, 3, 18, 18, 15, columnMetadata=0, 108, 2, 0, 0, 0, 765, 0, 0, 0, 765, columnNullability={2, 5, 6, 7, 8, 9, 10}, eventMetadata=null}}' at offset {ts_sec=1709947974, file=binlog.000888, pos=58731442, gtids=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, server_id=175348621, event=1} for table property_pureprop.notes whose schema isn't known to this connector. One possible cause is an incomplete database schema history topic. Take a new snapshot in this case. Use the mysqlbinlog tool to view the problematic event: mysqlbinlog --start-position=58731505 --stop-position=58731588 --verbose binlog.000888 (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:31,189] ERROR [p1505d-debezium-202403090016|task-0] Error during binlog processing. Last offset stored = {ts_sec=1709947974, file=binlog.000888, pos=58731442, gtids=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, server_id=175348621, event=1}, binlog reader near position = binlog.000888/58731505 (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:31,189] ERROR [p1505d-debezium-202403090016|task-0] Producer failure (io.debezium.pipeline.ErrorHandler) io.debezium.DebeziumException: Error processing binlog event at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:305) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:884) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: io.debezium.DebeziumException: Encountered change event for table property_pureprop.notes whose schema isn't known to this connector at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.informAboutUnknownTableIfRequired(MySqlStreamingChangeEventSource.java:638) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.informAboutUnknownTableIfRequired(MySqlStreamingChangeEventSource.java:679) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleUpdateTableMetadata(MySqlStreamingChangeEventSource.java:594) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$17(MySqlStreamingChangeEventSource.java:853) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:285) ... 6 more [2024-03-09 01:33:31,191] INFO [p1505d-debezium-202403090016|task-0] Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:31,367] ERROR [p1505d-debezium-202403090016|task-0] WorkerSourceTask{id=p1505d-debezium-202403090016-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:305) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:884) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: io.debezium.DebeziumException: Error processing binlog event ... 7 more Caused by: io.debezium.DebeziumException: Encountered change event for table property_pureprop.notes whose schema isn't known to this connector at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.informAboutUnknownTableIfRequired(MySqlStreamingChangeEventSource.java:638) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.informAboutUnknownTableIfRequired(MySqlStreamingChangeEventSource.java:679) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleUpdateTableMetadata(MySqlStreamingChangeEventSource.java:594) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$17(MySqlStreamingChangeEventSource.java:853) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:285) ... 6 more [2024-03-09 01:33:31,368] INFO [p1505d-debezium-202403090016|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask) Mar 09, 2024 1:33:31 AM com.github.shyiko.mysql.binlog.BinaryLogClient$5 run INFO: threadExecutor is shut down, terminating keepalive thread [2024-03-09 01:33:31,470] INFO [p1505d-debezium-202403090016|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-03-09 01:33:31,470] INFO [p1505d-debezium-202403090016|task-0] Stopped reading binlog after 0 events, last recorded offset: {ts_sec=1709947974, file=binlog.000888, pos=58731442, gtids=6bff9d11-2e33-11ed-9369-0ab14bb7ddc2:1-73269247,7bb33421-2e34-11ed-b018-06d64c3d8bfe:1-431755073,7f1e2a75-2ef2-11ed-ba7d-0a4e4d56a64d:1-5898, server_id=175348621, event=30414} (io.debezium.connector.mysql.MySqlStreamingChangeEventSource) [2024-03-09 01:33:31,470] INFO [p1505d-debezium-202403090016|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor) [2024-03-09 01:33:31,471] INFO [p1505d-debezium-202403090016|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry) [2024-03-09 01:33:31,472] INFO [p1505d-debezium-202403090016|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2024-03-09 01:33:31,473] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=p1505d-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2024-03-09 01:33:31,474] INFO [p1505d-debezium-202403090016|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,474] INFO [p1505d-debezium-202403090016|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,474] INFO [p1505d-debezium-202403090016|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,474] INFO [p1505d-debezium-202403090016|task-0] App info kafka.producer for p1505d-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 01:33:31,475] INFO [p1505d-debezium-202403090016|task-0] [Producer clientId=connector-producer-p1505d-debezium-202403090016-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2024-03-09 01:33:31,476] INFO [p1505d-debezium-202403090016|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,476] INFO [p1505d-debezium-202403090016|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,476] INFO [p1505d-debezium-202403090016|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,476] INFO [p1505d-debezium-202403090016|task-0] App info kafka.producer for connector-producer-p1505d-debezium-202403090016-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 01:33:31,477] INFO [p1505d-debezium-202403090016|task-0] App info kafka.admin.client for connector-adminclient-p1505d-debezium-202403090016-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2024-03-09 01:33:31,478] INFO [p1505d-debezium-202403090016|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,478] INFO [p1505d-debezium-202403090016|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2024-03-09 01:33:31,478] INFO [p1505d-debezium-202403090016|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics)