debezium-connector-3 | 2024-10-19 08:56:47,021 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,049 INFO || Successfully tested connection for jdbc:postgresql://172.25.155.233:5417/postgres with user 'postgres' [io.debezium.connector.postgresql.PostgresConnector] debezium-connector-3 | 2024-10-19 08:56:47,058 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:47,061 INFO || AbstractConfig values: debezium-connector-3 | [org.apache.kafka.common.config.AbstractConfig] debezium-connector-3 | 2024-10-19 08:56:47,068 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Connector postgres-connector config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,072 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,072 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,075 INFO || 172.22.0.1 - - [19/Oct/2024:08:56:47 +0000] "POST /connectors HTTP/1.1" 201 1928 "-" "curl/7.81.0" 62 [org.apache.kafka.connect.runtime.rest.RestServer] debezium-connector-3 | 2024-10-19 08:56:47,076 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Successfully joined group with generation Generation{generationId=88, memberId='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,085 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Successfully synced group in generation Generation{generationId=88, memberId='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,086 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Joined group at generation 88 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', leaderUrl='http://172.22.0.2:8083/', offset=217, connectorIds=[postgres-connector], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,086 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Starting connectors and tasks using config offset 217 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,086 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Starting connector postgres-connector [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,087 INFO || Creating connector postgres-connector of type io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,087 INFO || SourceConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.SourceConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,088 INFO || EnrichedConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,089 INFO || Instantiated connector postgres-connector with version 2.5.0.Final of type class io.debezium.connector.postgresql.PostgresConnector [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,089 INFO || Finished creating connector postgres-connector [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,089 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,092 INFO || SourceConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.SourceConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,092 INFO || EnrichedConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,116 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Tasks [postgres-connector-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,121 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,122 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,125 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Successfully joined group with generation Generation{generationId=89, memberId='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,136 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Successfully synced group in generation Generation{generationId=89, memberId='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,136 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Joined group at generation 89 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-444e2f31-4da3-4ffa-ba1c-8669434ad714', leaderUrl='http://172.22.0.2:8083/', offset=219, connectorIds=[postgres-connector], taskIds=[postgres-connector-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,137 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Starting connectors and tasks using config offset 219 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,138 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Starting task postgres-connector-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,138 INFO || Creating task postgres-connector-0 [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,140 INFO || ConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.ConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,143 INFO || EnrichedConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,144 INFO || TaskConfig values: debezium-connector-3 | task.class = class io.debezium.connector.postgresql.PostgresConnectorTask debezium-connector-3 | [org.apache.kafka.connect.runtime.TaskConfig] debezium-connector-3 | 2024-10-19 08:56:47,145 INFO || Instantiated task postgres-connector-0 with version 2.5.0.Final of type io.debezium.connector.postgresql.PostgresConnectorTask [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,146 INFO || JsonConverterConfig values: debezium-connector-3 | converter.type = key debezium-connector-3 | decimal.format = BASE64 debezium-connector-3 | replace.null.with.default = true debezium-connector-3 | schemas.cache.size = 1000 debezium-connector-3 | schemas.enable = true debezium-connector-3 | [org.apache.kafka.connect.json.JsonConverterConfig] debezium-connector-3 | 2024-10-19 08:56:47,146 INFO || Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task postgres-connector-0 using the worker config [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,147 INFO || JsonConverterConfig values: debezium-connector-3 | converter.type = value debezium-connector-3 | decimal.format = BASE64 debezium-connector-3 | replace.null.with.default = true debezium-connector-3 | schemas.cache.size = 1000 debezium-connector-3 | schemas.enable = true debezium-connector-3 | [org.apache.kafka.connect.json.JsonConverterConfig] debezium-connector-3 | 2024-10-19 08:56:47,147 INFO || Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task postgres-connector-0 using the worker config [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,147 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task postgres-connector-0 using the worker config [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,148 INFO || SourceConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.SourceConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,148 INFO || EnrichedConnectorConfig values: debezium-connector-3 | config.action.reload = restart debezium-connector-3 | connector.class = io.debezium.connector.postgresql.PostgresConnector debezium-connector-3 | errors.log.enable = false debezium-connector-3 | errors.log.include.messages = false debezium-connector-3 | errors.retry.delay.max.ms = 60000 debezium-connector-3 | errors.retry.timeout = 0 debezium-connector-3 | errors.tolerance = none debezium-connector-3 | exactly.once.support = requested debezium-connector-3 | header.converter = null debezium-connector-3 | key.converter = null debezium-connector-3 | name = postgres-connector debezium-connector-3 | offsets.storage.topic = null debezium-connector-3 | predicates = [] debezium-connector-3 | tasks.max = 1 debezium-connector-3 | topic.creation.groups = [] debezium-connector-3 | transaction.boundary = poll debezium-connector-3 | transaction.boundary.interval.ms = null debezium-connector-3 | transforms = [] debezium-connector-3 | value.converter = null debezium-connector-3 | [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,148 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] debezium-connector-3 | 2024-10-19 08:56:47,149 INFO || ProducerConfig values: debezium-connector-3 | acks = -1 debezium-connector-3 | auto.include.jmx.reporter = true debezium-connector-3 | batch.size = 16384 debezium-connector-3 | bootstrap.servers = [kafka-01.sbkafka.infiniband.vn:31504, kafka-02.sbkafka.infiniband.vn:30969, kafka-03.sbkafka.infiniband.vn:31924] debezium-connector-3 | buffer.memory = 33554432 debezium-connector-3 | client.dns.lookup = use_all_dns_ips debezium-connector-3 | client.id = vcr-cdc-sandbox debezium-connector-3 | compression.type = none debezium-connector-3 | connections.max.idle.ms = 540000 debezium-connector-3 | delivery.timeout.ms = 2147483647 debezium-connector-3 | enable.idempotence = false debezium-connector-3 | interceptor.classes = [] debezium-connector-3 | key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer debezium-connector-3 | linger.ms = 0 debezium-connector-3 | max.block.ms = 9223372036854775807 debezium-connector-3 | max.in.flight.requests.per.connection = 1 debezium-connector-3 | max.request.size = 1048576 debezium-connector-3 | metadata.max.age.ms = 300000 debezium-connector-3 | metadata.max.idle.ms = 300000 debezium-connector-3 | metric.reporters = [] debezium-connector-3 | metrics.num.samples = 2 debezium-connector-3 | metrics.recording.level = INFO debezium-connector-3 | metrics.sample.window.ms = 30000 debezium-connector-3 | partitioner.adaptive.partitioning.enable = true debezium-connector-3 | partitioner.availability.timeout.ms = 0 debezium-connector-3 | partitioner.class = null debezium-connector-3 | partitioner.ignore.keys = false debezium-connector-3 | receive.buffer.bytes = 32768 debezium-connector-3 | reconnect.backoff.max.ms = 1000 debezium-connector-3 | reconnect.backoff.ms = 50 debezium-connector-3 | request.timeout.ms = 30000 debezium-connector-3 | retries = 2147483647 debezium-connector-3 | retry.backoff.ms = 100 debezium-connector-3 | sasl.client.callback.handler.class = null debezium-connector-3 | sasl.jaas.config = [hidden] debezium-connector-3 | sasl.kerberos.kinit.cmd = /usr/bin/kinit debezium-connector-3 | sasl.kerberos.min.time.before.relogin = 60000 debezium-connector-3 | sasl.kerberos.service.name = null debezium-connector-3 | sasl.kerberos.ticket.renew.jitter = 0.05 debezium-connector-3 | sasl.kerberos.ticket.renew.window.factor = 0.8 debezium-connector-3 | sasl.login.callback.handler.class = null debezium-connector-3 | sasl.login.class = null debezium-connector-3 | sasl.login.connect.timeout.ms = null debezium-connector-3 | sasl.login.read.timeout.ms = null debezium-connector-3 | sasl.login.refresh.buffer.seconds = 300 debezium-connector-3 | sasl.login.refresh.min.period.seconds = 60 debezium-connector-3 | sasl.login.refresh.window.factor = 0.8 debezium-connector-3 | sasl.login.refresh.window.jitter = 0.05 debezium-connector-3 | sasl.login.retry.backoff.max.ms = 10000 debezium-connector-3 | sasl.login.retry.backoff.ms = 100 debezium-connector-3 | sasl.mechanism = SCRAM-SHA-512 debezium-connector-3 | sasl.oauthbearer.clock.skew.seconds = 30 debezium-connector-3 | sasl.oauthbearer.expected.audience = null debezium-connector-3 | sasl.oauthbearer.expected.issuer = null debezium-connector-3 | sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 debezium-connector-3 | sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 debezium-connector-3 | sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 debezium-connector-3 | sasl.oauthbearer.jwks.endpoint.url = null debezium-connector-3 | sasl.oauthbearer.scope.claim.name = scope debezium-connector-3 | sasl.oauthbearer.sub.claim.name = sub debezium-connector-3 | sasl.oauthbearer.token.endpoint.url = null debezium-connector-3 | security.protocol = SASL_SSL debezium-connector-3 | security.providers = null debezium-connector-3 | send.buffer.bytes = 131072 debezium-connector-3 | socket.connection.setup.timeout.max.ms = 30000 debezium-connector-3 | socket.connection.setup.timeout.ms = 10000 debezium-connector-3 | ssl.cipher.suites = null debezium-connector-3 | ssl.enabled.protocols = [TLSv1.2, TLSv1.3] debezium-connector-3 | ssl.endpoint.identification.algorithm = debezium-connector-3 | ssl.engine.factory.class = null debezium-connector-3 | ssl.key.password = null debezium-connector-3 | ssl.keymanager.algorithm = SunX509 debezium-connector-3 | ssl.keystore.certificate.chain = null debezium-connector-3 | ssl.keystore.key = null debezium-connector-3 | ssl.keystore.location = null debezium-connector-3 | ssl.keystore.password = null debezium-connector-3 | ssl.keystore.type = JKS debezium-connector-3 | ssl.protocol = TLSv1.3 debezium-connector-3 | ssl.provider = null debezium-connector-3 | ssl.secure.random.implementation = null debezium-connector-3 | ssl.trustmanager.algorithm = PKIX debezium-connector-3 | ssl.truststore.certificates = null debezium-connector-3 | ssl.truststore.location = null debezium-connector-3 | ssl.truststore.password = null debezium-connector-3 | ssl.truststore.type = JKS debezium-connector-3 | transaction.timeout.ms = 60000 debezium-connector-3 | transactional.id = null debezium-connector-3 | value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer debezium-connector-3 | [org.apache.kafka.clients.producer.ProducerConfig] debezium-connector-3 | 2024-10-19 08:56:47,165 INFO || These configurations '[metrics.context.connect.group.id, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] debezium-connector-3 | 2024-10-19 08:56:47,165 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] debezium-connector-3 | 2024-10-19 08:56:47,165 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] debezium-connector-3 | 2024-10-19 08:56:47,165 INFO || Kafka startTimeMs: 1729328207165 [org.apache.kafka.common.utils.AppInfoParser] debezium-connector-3 | 2024-10-19 08:56:47,168 INFO || [Worker clientId=connect-1, groupId=vcr-cdc-sandbox] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] debezium-connector-3 | 2024-10-19 08:56:47,171 INFO || Starting PostgresConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,172 INFO || connector.class = io.debezium.connector.postgresql.PostgresConnector [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,172 INFO || producer.sasl.jaas.config = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,172 INFO || auto.create.topics.enable = true [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,172 INFO || schema.history.internal.consumer.sasl.jaas.config = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || database.history.kafka.topic = schema-changes.postgres [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || schema.include.list = public [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || topic.prefix = vcr-cdc [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || schema.history.internal.producer.security.protocol = SASL_SSL [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || ssl.truststore.password = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,173 INFO || schema.history.internal.producer.sasl.mechanism = SCRAM-SHA-512 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,174 INFO || ssl.mode = disable [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,174 INFO || database.user = postgres [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,174 INFO || database.dbname = postgres [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,174 INFO || producer.security.protocol = SASL_SSL [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || database.history.kafka.bootstrap.servers = kafka-01.sbkafka.infiniband.vn:31504,kafka-02.sbkafka.infiniband.vn:30969,kafka-03.sbkafka.infiniband.vn:31924 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || database.server.name = event_log [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || schema.history.internal.kafka.bootstrap.servers = kafka-01.sbkafka.infiniband.vn:31504,kafka-02.sbkafka.infiniband.vn:30969,kafka-03.sbkafka.infiniband.vn:31924 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || database.port = 5417 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || plugin.name = pgoutput [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || producer.sasl.mechanism = SCRAM-SHA-512 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,175 INFO || ssl.truststore.location = /etc/kafka/server.truststore [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || task.class = io.debezium.connector.postgresql.PostgresConnectorTask [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || database.hostname = 172.25.155.233 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || name = postgres-connector [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || schema.history.internal.consumer.sasl.mechanism = SCRAM-SHA-512 [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || schema.history.internal.producer.sasl.jaas.config = ******** [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || table.include.list = public.tag,public.artifact,public.repository [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,176 INFO || schema.history.internal.consumer.security.protocol = SASL_SSL [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,177 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,178 INFO || Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy [io.debezium.config.CommonConnectorConfig] debezium-connector-3 | 2024-10-19 08:56:47,187 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,187 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,188 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,188 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,198 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:47,244 INFO || No previous offsets found [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,290 INFO Postgres|vcr-cdc|postgres-connector-task user 'postgres' connected to database 'postgres' on PostgreSQL 17.0 on x86_64-pc-linux-gnu, compiled by gcc (Debian 12.2.0-14) 12.2.0, 64-bit with roles: debezium-connector-3 | role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_use_reserved_connections' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_create_subscription' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'repl_user' [superuser: false, replication: true, inherit: true, create role: false, create db: false, can log in: true] debezium-connector-3 | role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'pg_maintain' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] debezium-connector-3 | role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] [io.debezium.connector.postgresql.PostgresConnectorTask] debezium-connector-3 | 2024-10-19 08:56:47,293 INFO Postgres|vcr-cdc|postgres-connector-task Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/1768D08}, catalogXmin=1484] [io.debezium.connector.postgresql.connection.PostgresConnection] debezium-connector-3 | 2024-10-19 08:56:47,293 INFO Postgres|vcr-cdc|postgres-connector-task No previous offset found [io.debezium.connector.postgresql.PostgresConnectorTask] debezium-connector-3 | 2024-10-19 08:56:47,295 INFO Postgres|vcr-cdc|postgres-connector-task Requested thread factory for connector PostgresConnector, id = vcr-cdc named = SignalProcessor [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,295 INFO Postgres|vcr-cdc|postgres-connector-task Requested thread factory for connector PostgresConnector, id = vcr-cdc named = change-event-source-coordinator [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,296 INFO Postgres|vcr-cdc|postgres-connector-task Requested thread factory for connector PostgresConnector, id = vcr-cdc named = blocking-snapshot [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,296 INFO Postgres|vcr-cdc|postgres-connector-task Creating thread debezium-postgresconnector-vcr-cdc-change-event-source-coordinator [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,297 INFO Postgres|vcr-cdc|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,299 INFO Postgres|vcr-cdc|postgres-connector-task SignalProcessor started. Scheduling it every 5000ms [io.debezium.pipeline.signal.SignalProcessor] debezium-connector-3 | 2024-10-19 08:56:47,300 INFO Postgres|vcr-cdc|postgres-connector-task Creating thread debezium-postgresconnector-vcr-cdc-SignalProcessor [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,300 INFO Postgres|vcr-cdc|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,300 INFO || WorkerSourceTask{id=postgres-connector-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] debezium-connector-3 | 2024-10-19 08:56:47,300 INFO Postgres|vcr-cdc|snapshot Taking initial snapshot for new datasource [io.debezium.connector.postgresql.snapshot.InitialSnapshotter] debezium-connector-3 | 2024-10-19 08:56:47,301 INFO Postgres|vcr-cdc|snapshot According to the connector configuration data will be snapshotted [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,301 INFO Postgres|vcr-cdc|snapshot Snapshot step 1 - Preparing [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,306 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,306 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,307 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,307 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,354 INFO Postgres|vcr-cdc|snapshot Snapshot step 2 - Determining captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,357 INFO Postgres|vcr-cdc|snapshot Adding table public.artifact to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,357 INFO Postgres|vcr-cdc|snapshot Adding table public.cve_allowlist to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,357 INFO Postgres|vcr-cdc|snapshot Adding table public.data_migrations to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,357 INFO Postgres|vcr-cdc|snapshot Adding table public.scanner_registration to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.task to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.report_vulnerability_record to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.job_queue_status to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.project_member to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.scan_report to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.user_group to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.role_permission to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.sbom_report to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.schema_migrations to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.audit_log to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.harbor_label to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.artifact_trash to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.vulnerability_record to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.artifact_blob to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.label_reference to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.project to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,358 INFO Postgres|vcr-cdc|snapshot Adding table public.retention_policy to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.permission_policy to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.schedule to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.replication_policy to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.artifact_reference to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.blob to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.project_blob to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.tag to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.execution to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.p2p_preheat_policy to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.artifact_accessory to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.project_metadata to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,359 INFO Postgres|vcr-cdc|snapshot Adding table public.registry to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.alembic_version to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.notification_policy to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.oidc_user to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.robot to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.repository to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.quota_usage to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.immutable_tag_rule to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.role to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.p2p_preheat_instance to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.properties to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.harbor_user to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.access to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.job_log to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.quota to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,360 INFO Postgres|vcr-cdc|snapshot Adding table public.system_artifact to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,361 INFO Postgres|vcr-cdc|snapshot Created connection pool with 1 threads [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,361 INFO Postgres|vcr-cdc|snapshot Snapshot step 3 - Locking captured tables [public.tag, public.artifact, public.repository] [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,361 INFO Postgres|vcr-cdc|snapshot Snapshot step 4 - Determining snapshot offset [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,361 INFO Postgres|vcr-cdc|snapshot Creating initial offset context [io.debezium.connector.postgresql.PostgresOffsetContext] debezium-connector-3 | 2024-10-19 08:56:47,363 INFO Postgres|vcr-cdc|snapshot Read xlogStart at 'LSN{0/1768ED0}' from transaction '1486' [io.debezium.connector.postgresql.PostgresOffsetContext] debezium-connector-3 | 2024-10-19 08:56:47,364 INFO Postgres|vcr-cdc|snapshot Read xlogStart at 'LSN{0/1768ED0}' from transaction '1486' [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,364 INFO Postgres|vcr-cdc|snapshot Snapshot step 5 - Reading structure of captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,364 INFO Postgres|vcr-cdc|snapshot Reading structure of schema 'public' of catalog 'postgres' [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,416 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,416 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,416 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,417 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,418 INFO Postgres|vcr-cdc|snapshot Snapshot step 6 - Persisting schema history [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,418 INFO Postgres|vcr-cdc|snapshot Snapshot step 7 - Snapshotting data [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,418 INFO Postgres|vcr-cdc|snapshot Creating snapshot worker pool with 1 worker thread(s) [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,418 INFO Postgres|vcr-cdc|snapshot For table 'public.tag' using select statement: 'SELECT "id", "repository_id", "artifact_id", "name", "push_time", "pull_time" FROM "public"."tag"' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,419 INFO Postgres|vcr-cdc|snapshot For table 'public.artifact' using select statement: 'SELECT "id", "project_id", "repository_name", "digest", "type", "pull_time", "push_time", "repository_id", "media_type", "manifest_media_type", "size", "extra_attrs", "annotations", "icon", "artifact_type" FROM "public"."artifact"' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,419 INFO Postgres|vcr-cdc|snapshot For table 'public.repository' using select statement: 'SELECT "repository_id", "name", "project_id", "description", "pull_count", "star_count", "creation_time", "update_time" FROM "public"."repository"' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,420 INFO Postgres|vcr-cdc|snapshot Exporting data from table 'public.tag' (1 of 3 tables) [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,430 INFO Postgres|vcr-cdc|snapshot Finished exporting 4 records for table 'public.tag' (1 of 3 tables); total duration '00:00:00.01' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,431 INFO Postgres|vcr-cdc|snapshot Exporting data from table 'public.artifact' (2 of 3 tables) [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,438 INFO Postgres|vcr-cdc|snapshot Finished exporting 4 records for table 'public.artifact' (2 of 3 tables); total duration '00:00:00.007' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,439 INFO Postgres|vcr-cdc|snapshot Exporting data from table 'public.repository' (3 of 3 tables) [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,445 INFO Postgres|vcr-cdc|snapshot Finished exporting 4 records for table 'public.repository' (3 of 3 tables); total duration '00:00:00.006' [io.debezium.relational.RelationalSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,450 INFO Postgres|vcr-cdc|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,450 INFO Postgres|vcr-cdc|snapshot Snapshot completed [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,451 INFO Postgres|vcr-cdc|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='vcr-cdc'db='postgres', lsn=LSN{0/1768ED0}, txId=1486, timestamp=2024-10-19T08:56:47.303748Z, snapshot=FALSE, schema=public, table=repository], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,452 INFO Postgres|vcr-cdc|streaming Connected metrics set to 'true' [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,478 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.artifact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,480 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.repository' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,481 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.tag' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,482 INFO Postgres|vcr-cdc|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:47,482 INFO Postgres|vcr-cdc|streaming Retrieved latest position from stored offset 'LSN{0/1768ED0}' [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,482 INFO Postgres|vcr-cdc|streaming Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{0/1768ED0}' [io.debezium.connector.postgresql.connection.WalPositionLocator] debezium-connector-3 | 2024-10-19 08:56:47,483 INFO Postgres|vcr-cdc|streaming Initializing PgOutput logical decoder publication [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] debezium-connector-3 | 2024-10-19 08:56:47,528 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,530 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,530 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,530 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,535 INFO Postgres|vcr-cdc|streaming Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{0/1768D08}, catalogXmin=1484] [io.debezium.connector.postgresql.connection.PostgresConnection] debezium-connector-3 | 2024-10-19 08:56:47,538 INFO Postgres|vcr-cdc|streaming Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:47,551 INFO Postgres|vcr-cdc|streaming Requested thread factory for connector PostgresConnector, id = vcr-cdc named = keep-alive [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,551 INFO Postgres|vcr-cdc|streaming Creating thread debezium-postgresconnector-vcr-cdc-keep-alive [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:47,641 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,641 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,641 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,641 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,751 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,752 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,752 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,752 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,784 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.artifact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,785 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.repository' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,786 INFO Postgres|vcr-cdc|streaming REPLICA IDENTITY for 'public.tag' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns [io.debezium.connector.postgresql.PostgresSchema] debezium-connector-3 | 2024-10-19 08:56:47,788 INFO Postgres|vcr-cdc|streaming Searching for WAL resume position [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:47,803 ERROR || WorkerSourceTask{id=postgres-connector-0} failed to send record to vcr-cdc.public.tag: [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] debezium-connector-3 | org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed debezium-connector-3 | Caused by: javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:131) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:360) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:303) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:298) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1357) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(CertificateMessage.java:1232) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(CertificateMessage.java:1175) debezium-connector-3 | at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:392) debezium-connector-3 | at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:443) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1076) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1063) debezium-connector-3 | at java.base/java.security.AccessController.doPrivileged(Native Method) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1010) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:435) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:523) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:373) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:293) debezium-connector-3 | at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) debezium-connector-3 | at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) debezium-connector-3 | at org.apache.kafka.common.network.Selector.poll(Selector.java:481) debezium-connector-3 | at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:571) debezium-connector-3 | at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:343) debezium-connector-3 | at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:246) debezium-connector-3 | at java.base/java.lang.Thread.run(Thread.java:829) debezium-connector-3 | Caused by: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:439) debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:306) debezium-connector-3 | at java.base/sun.security.validator.Validator.validate(Validator.java:264) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.validate(X509TrustManagerImpl.java:313) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:276) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1335) debezium-connector-3 | ... 19 more debezium-connector-3 | Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.provider.certpath.SunCertPathBuilder.build(SunCertPathBuilder.java:146) debezium-connector-3 | at java.base/sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:127) debezium-connector-3 | at java.base/java.security.cert.CertPathBuilder.build(CertPathBuilder.java:297) debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:434) debezium-connector-3 | ... 25 more debezium-connector-3 | 2024-10-19 08:56:47,916 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:47,917 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,917 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:47,917 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,038 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:48,038 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,038 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,039 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,153 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:48,154 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,154 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:48,154 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,129 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:49,129 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,129 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,129 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,241 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:49,242 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,242 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,242 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,355 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:49,356 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,356 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:49,356 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,224 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:50,224 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,225 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,225 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,335 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:50,335 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,335 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,336 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,445 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:50,446 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,446 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:50,446 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,363 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:51,365 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,366 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,366 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,480 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:51,481 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,481 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,481 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,595 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:51,595 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,596 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:51,596 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,359 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-03.sbkafka.infiniband.vn/172.26.24.80 (channelId=-3) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:52,359 INFO || [Producer clientId=vcr-cdc-sandbox] Node -3 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,361 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -3 (kafka-03.sbkafka.infiniband.vn/172.26.24.80:31924) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,362 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-03.sbkafka.infiniband.vn:31924 (id: -3 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,525 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-01.sbkafka.infiniband.vn/172.26.24.80 (channelId=-1) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:52,526 INFO || [Producer clientId=vcr-cdc-sandbox] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,526 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -1 (kafka-01.sbkafka.infiniband.vn/172.26.24.80:31504) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,526 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-01.sbkafka.infiniband.vn:31504 (id: -1 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,693 INFO || [Producer clientId=vcr-cdc-sandbox] Failed authentication with kafka-02.sbkafka.infiniband.vn/172.26.24.80 (channelId=-2) (SSL handshake failed) [org.apache.kafka.common.network.Selector] debezium-connector-3 | 2024-10-19 08:56:52,693 INFO || [Producer clientId=vcr-cdc-sandbox] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,693 ERROR || [Producer clientId=vcr-cdc-sandbox] Connection to node -2 (kafka-02.sbkafka.infiniband.vn/172.26.24.80:30969) failed authentication due to: SSL handshake failed [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,694 WARN || [Producer clientId=vcr-cdc-sandbox] Bootstrap broker kafka-02.sbkafka.infiniband.vn:30969 (id: -2 rack: null) disconnected [org.apache.kafka.clients.NetworkClient] debezium-connector-3 | 2024-10-19 08:56:52,806 INFO || WorkerSourceTask{id=postgres-connector-0} Committing offsets for 0 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] debezium-connector-3 | 2024-10-19 08:56:52,806 ERROR || WorkerSourceTask{id=postgres-connector-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] debezium-connector-3 | org.apache.kafka.connect.errors.ConnectException: Unrecoverable exception from producer send callback debezium-connector-3 | at org.apache.kafka.connect.runtime.WorkerSourceTask.maybeThrowProducerSendException(WorkerSourceTask.java:340) debezium-connector-3 | at org.apache.kafka.connect.runtime.WorkerSourceTask.prepareToSendRecord(WorkerSourceTask.java:133) debezium-connector-3 | at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:411) debezium-connector-3 | at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:367) debezium-connector-3 | at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) debezium-connector-3 | at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) debezium-connector-3 | at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77) debezium-connector-3 | at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:236) debezium-connector-3 | at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) debezium-connector-3 | at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) debezium-connector-3 | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) debezium-connector-3 | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) debezium-connector-3 | at java.base/java.lang.Thread.run(Thread.java:829) debezium-connector-3 | Caused by: org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed debezium-connector-3 | Caused by: javax.net.ssl.SSLHandshakeException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:131) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:360) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:303) debezium-connector-3 | at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:298) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1357) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(CertificateMessage.java:1232) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(CertificateMessage.java:1175) debezium-connector-3 | at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:392) debezium-connector-3 | at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:443) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1076) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1063) debezium-connector-3 | at java.base/java.security.AccessController.doPrivileged(Native Method) debezium-connector-3 | at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1010) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:435) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:523) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:373) debezium-connector-3 | at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:293) debezium-connector-3 | at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) debezium-connector-3 | at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) debezium-connector-3 | at org.apache.kafka.common.network.Selector.poll(Selector.java:481) debezium-connector-3 | at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:571) debezium-connector-3 | at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:343) debezium-connector-3 | at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:246) debezium-connector-3 | at java.base/java.lang.Thread.run(Thread.java:829) debezium-connector-3 | Caused by: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:439) debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:306) debezium-connector-3 | at java.base/sun.security.validator.Validator.validate(Validator.java:264) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.validate(X509TrustManagerImpl.java:313) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:276) debezium-connector-3 | at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) debezium-connector-3 | at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1335) debezium-connector-3 | ... 19 more debezium-connector-3 | Caused by: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target debezium-connector-3 | at java.base/sun.security.provider.certpath.SunCertPathBuilder.build(SunCertPathBuilder.java:146) debezium-connector-3 | at java.base/sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:127) debezium-connector-3 | at java.base/java.security.cert.CertPathBuilder.build(CertPathBuilder.java:297) debezium-connector-3 | at java.base/sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:434) debezium-connector-3 | ... 25 more debezium-connector-3 | 2024-10-19 08:56:52,808 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] debezium-connector-3 | 2024-10-19 08:56:52,853 INFO Postgres|vcr-cdc|streaming WAL resume position 'null' discovered [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:52,857 INFO Postgres|vcr-cdc|streaming Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:52,861 INFO Postgres|vcr-cdc|streaming Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:52,883 INFO Postgres|vcr-cdc|streaming Initializing PgOutput logical decoder publication [io.debezium.connector.postgresql.connection.PostgresReplicationConnection] debezium-connector-3 | 2024-10-19 08:56:52,898 INFO Postgres|vcr-cdc|streaming Requested thread factory for connector PostgresConnector, id = vcr-cdc named = keep-alive [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:52,898 INFO Postgres|vcr-cdc|streaming Creating thread debezium-postgresconnector-vcr-cdc-keep-alive [io.debezium.util.Threads] debezium-connector-3 | 2024-10-19 08:56:52,899 INFO Postgres|vcr-cdc|streaming Processing messages [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource] debezium-connector-3 | 2024-10-19 08:56:52,928 INFO Postgres|vcr-cdc|streaming Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:52,929 INFO Postgres|vcr-cdc|streaming Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:52,930 INFO Postgres|vcr-cdc|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:52,930 INFO Postgres|vcr-cdc|streaming Connected metrics set to 'false' [io.debezium.pipeline.ChangeEventSourceCoordinator] debezium-connector-3 | 2024-10-19 08:56:52,930 INFO || SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] debezium-connector-3 | 2024-10-19 08:56:52,931 INFO || Debezium ServiceRegistry stopped. [io.debezium.service.DefaultServiceRegistry] debezium-connector-3 | 2024-10-19 08:56:52,932 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] debezium-connector-3 | 2024-10-19 08:56:52,932 INFO || [Producer clientId=vcr-cdc-sandbox] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] debezium-connector-3 | 2024-10-19 08:56:52,934 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] debezium-connector-3 | 2024-10-19 08:56:52,934 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] debezium-connector-3 | 2024-10-19 08:56:52,934 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] debezium-connector-3 | 2024-10-19 08:56:52,935 INFO || App info kafka.producer for vcr-cdc-sandbox unregistered [org.apache.kafka.common.utils.AppInfoParser]