__ __ _ ____/ /___ / /_ ___ ____ (_)__ __ ____ ___ / __ // _ \ / __ \ / _ \/_ / / // / / // __ `__ \ / /_/ // __// /_/ // __/ / /_ / // /_/ // / / / / / \__,_/ \___//_.___/ \___/ /___//_/ \__,_//_/ /_/ /_/ Powered by Quarkus 3.2.3.Final 2023-11-10 19:32:20,886 INFO [io.deb.ser.BaseChangeConsumer] (main) Using 'io.debezium.server.BaseChangeConsumer$$Lambda$385/0x000000084046fc40@5b5e7036' stream name mapper 2023-11-10 19:32:21,026 INFO [io.deb.ser.htt.HttpChangeConsumer] (main) Using http content-type type application/json 2023-11-10 19:32:21,030 INFO [io.deb.ser.htt.HttpChangeConsumer] (main) Using sink URL: http://foo 2023-11-10 19:32:21,034 INFO [io.deb.ser.DebeziumServer] (main) Consumer 'io.debezium.server.http.HttpChangeConsumer' instantiated 2023-11-10 19:32:21,278 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2023-11-10 19:32:21,282 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2023-11-10 19:32:21,300 INFO [io.deb.emb.EmbeddedEngine$EmbeddedConfig] (main) EmbeddedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.file.filename = /debezium/data/offsets.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none 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 task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2023-11-10 19:32:21,301 WARN [org.apa.kaf.con.run.WorkerConfig] (main) Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2023-11-10 19:32:21,312 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2023-11-10 19:32:21,313 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2023-11-10 19:32:21,314 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (main) JsonConverterConfig values: converter.type = header decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true 2023-11-10 19:32:21,317 INFO [io.deb.ser.DebeziumServer] (main) Engine executor started 2023-11-10 19:32:21,450 INFO [io.quarkus] (main) debezium-server-dist 2.4.0.Final on JVM (powered by Quarkus 3.2.3.Final) started in 6.020s. Listening on: http://0.0.0.0:8080 2023-11-10 19:32:21,451 INFO [io.quarkus] (main) Profile prod activated. 2023-11-10 19:32:21,452 INFO [io.quarkus] (main) Installed features: [cdi, kubernetes-client, resteasy-jackson, smallrye-context-propagation, smallrye-health, vertx] 2023-11-10 19:32:21,951 INFO [io.deb.con.mys.MySqlConnector] (pool-8-thread-1) Successfully tested connection for jdbc:mysql://cloudsql-master-instance:3306/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'debezium' 2023-11-10 19:32:21,959 INFO [io.deb.jdb.JdbcConnection] (pool-9-thread-1) Connection gracefully closed 2023-11-10 19:32:21,994 INFO [org.apa.kaf.con.jso.JsonConverterConfig] (pool-8-thread-1) JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false 2023-11-10 19:32:21,995 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-8-thread-1) Starting FileOffsetBackingStore with file /debezium/data/offsets.dat 2023-11-10 19:32:22,023 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) Starting MySqlConnectorTask with configuration: 2023-11-10 19:32:22,027 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) connector.class = io.debezium.connector.mysql.MySqlConnector 2023-11-10 19:32:22,036 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) offset.storage.http.url = http://foo 2023-11-10 19:32:22,036 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.clientCertificateKeyStorePassword = ******** 2023-11-10 19:32:22,037 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.trustCertificateKeyStoreUrl = file:/debezium/external-configuration/cloudsql/truststore.jks 2023-11-10 19:32:22,037 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.trustCertificateKeyStorePassword = ******** 2023-11-10 19:32:22,037 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) schema.include.list = migrations 2023-11-10 19:32:22,037 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) header.converter.header = json 2023-11-10 19:32:22,037 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.useSSL = true 2023-11-10 19:32:22,038 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.requireSSL = true 2023-11-10 19:32:22,038 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) schema.history.internal.file.filename = /debezium/data/dbhistory.dat 2023-11-10 19:32:22,038 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) topic.prefix = accounts-debezium 2023-11-10 19:32:22,038 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) offset.storage.file.filename = /debezium/data/offsets.dat 2023-11-10 19:32:22,038 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.verifyServerCertificate = true 2023-11-10 19:32:22,039 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) errors.retry.delay.initial.ms = 300 2023-11-10 19:32:22,039 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) value.converter = org.apache.kafka.connect.json.JsonConverter 2023-11-10 19:32:22,039 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) key.converter = org.apache.kafka.connect.json.JsonConverter 2023-11-10 19:32:22,039 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) header.converter.value = json 2023-11-10 19:32:22,039 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.dbname = migrations 2023-11-10 19:32:22,040 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.user = debezium 2023-11-10 19:32:22,040 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) header.converter.key = json 2023-11-10 19:32:22,040 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.server.id = 123456 2023-11-10 19:32:22,040 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore 2023-11-10 19:32:22,040 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) key.converter.value = json 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) value.converter.header = json 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) key.converter.header = json 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) offset.flush.timeout.ms = 5000 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) errors.retry.delay.max.ms = 10000 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) value.converter.value = json 2023-11-10 19:32:22,041 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) offset.flush.interval.ms = 60000 2023-11-10 19:32:22,042 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) driver.clientCertificateKeyStoreUrl = file:/debezium/external-configuration/cloudsql/keystore.jks 2023-11-10 19:32:22,042 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory 2023-11-10 19:32:22,042 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) errors.max.retries = -1 2023-11-10 19:32:22,050 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.hostname = REDACTED 2023-11-10 19:32:22,051 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.password = ******** 2023-11-10 19:32:22,051 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) name = http 2023-11-10 19:32:22,051 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) schema.history.internal.http.url = http://REDACTED 2023-11-10 19:32:22,051 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) value.converter.key = json 2023-11-10 19:32:22,051 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) database.history = io.debezium.relational.history.FileDatabaseHistory 2023-11-10 19:32:22,052 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) key.converter.key = json 2023-11-10 19:32:22,083 INFO [io.deb.con.CommonConnectorConfig] (pool-8-thread-1) Loading the custom source info struct maker plugin: io.debezium.connector.mysql.MySqlSourceInfoStructMaker 2023-11-10 19:32:22,135 INFO [io.deb.con.CommonConnectorConfig] (pool-8-thread-1) Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy 2023-11-10 19:32:22,279 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) No previous offsets found 2023-11-10 19:32:22,838 INFO [io.deb.con.mys.MySqlConnectorTask] (pool-8-thread-1) Closing connection before starting schema recovery 2023-11-10 19:32:22,845 INFO [io.deb.jdb.JdbcConnection] (pool-10-thread-1) Connection gracefully closed 2023-11-10 19:32:22,847 INFO [io.deb.con.mys.MySqlConnectorTask] (pool-8-thread-1) Connector started for the first time, database schema history recovery will not be executed 2023-11-10 19:32:22,848 INFO [io.deb.con.mys.MySqlConnectorTask] (pool-8-thread-1) Reconnecting after finishing schema recovery 2023-11-10 19:32:22,964 INFO [io.deb.uti.Threads] (pool-8-thread-1) Requested thread factory for connector MySqlConnector, id = accounts-debezium named = SignalProcessor 2023-11-10 19:32:23,010 INFO [io.deb.uti.Threads] (pool-8-thread-1) Requested thread factory for connector MySqlConnector, id = accounts-debezium named = change-event-source-coordinator 2023-11-10 19:32:23,011 INFO [io.deb.uti.Threads] (pool-8-thread-1) Requested thread factory for connector MySqlConnector, id = accounts-debezium named = blocking-snapshot 2023-11-10 19:32:23,017 INFO [io.deb.uti.Threads] (pool-8-thread-1) Creating thread debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator 2023-11-10 19:32:23,039 INFO [io.deb.pip.sig.SignalProcessor] (pool-8-thread-1) SignalProcessor started. Scheduling it every 5000ms 2023-11-10 19:32:23,040 INFO [io.deb.uti.Threads] (pool-8-thread-1) Creating thread debezium-mysqlconnector-accounts-debezium-SignalProcessor 2023-11-10 19:32:23,047 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Metrics registered 2023-11-10 19:32:23,055 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Context created 2023-11-10 19:32:23,073 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) No previous offset has been found 2023-11-10 19:32:23,073 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) According to the connector configuration both schema and data will be snapshotted 2023-11-10 19:32:23,081 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 1 - Preparing 2023-11-10 19:32:23,083 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 2 - Determining captured tables 2023-11-10 19:32:23,084 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Read list of available databases 2023-11-10 19:32:23,087 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) list of available databases is: [REDACTED] 2023-11-10 19:32:23,088 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Read list of available tables in each database 2023-11-10 19:32:23,203 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) snapshot continuing with database(s): [REDACTED] 2023-11-10 19:32:23,204 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Adding table REDACTED.REDACTED to the list of capture schema tables 2023-11-10 19:32:23,239 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Created connection pool with 1 threads 2023-11-10 19:32:23,240 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 3 - Locking captured tables [] 2023-11-10 19:32:23,251 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Flush and obtain global read lock to prevent writes to database 2023-11-10 19:32:23,258 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 4 - Determining snapshot offset 2023-11-10 19:32:23,265 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Read binlog position of MySQL primary server 2023-11-10 19:32:23,269 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) using binlog 'mysql-bin.000143' at position '7541176' and gtid 'b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730' 2023-11-10 19:32:23,270 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 5 - Reading structure of captured tables 2023-11-10 19:32:23,270 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) All eligible tables schema should be captured, capturing: [REDACTED] 2023-11-10 19:32:24,263 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Reading structure of database 'REDACTED' 2023-11-10 19:32:27,534 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 6 - Persisting schema history 2023-11-10 19:32:27,551 INFO [io.deb.rel.his.SchemaHistoryMetrics] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Already applied 1 database changes 2023-11-10 19:32:28,045 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Releasing global read lock to enable MySQL writes 2023-11-10 19:32:28,050 INFO [io.deb.con.mys.MySqlSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Writes to MySQL tables prevented for a total of 00:00:04.794 2023-11-10 19:32:28,050 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot step 7 - Snapshotting data 2023-11-10 19:32:28,052 INFO [io.deb.rel.RelationalSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Creating snapshot worker pool with 1 worker thread(s) 2023-11-10 19:32:28,059 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) 394 records sent during previous 00:00:06.042, last recorded offset of {server=accounts-debezium} partition is {ts_sec=1699644747, file=mysql-bin.000143, pos=7541176, gtids=b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730} 2023-11-10 19:32:28,061 INFO [io.deb.pip.sou.AbstractSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot - Final stage 2023-11-10 19:32:28,064 INFO [io.deb.pip.sou.AbstractSnapshotChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot completed 2023-11-10 19:32:28,280 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Snapshot ended with SnapshotResult [status=COMPLETED, offset=MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin.000143, currentBinlogPosition=7541176, currentRowNumber=0, serverId=0, sourceTime=2023-11-10T19:32:28.042Z, threadId=-1, currentQuery=null, tableIds=[workitems.workitem_type], databaseName=workitems], snapshotCompleted=true, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730, currentGtidSet=b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730, restartBinlogFilename=mysql-bin.000143, restartBinlogPosition=7541176, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] 2023-11-10 19:32:28,280 WARN [io.deb.rel.RelationalDatabaseSchema] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) After applying the include/exclude list filters, no changes will be captured. Please check your configuration! 2023-11-10 19:32:28,302 INFO [io.deb.uti.Threads] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Requested thread factory for connector MySqlConnector, id = accounts-debezium named = binlog-client 2023-11-10 19:32:28,310 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Enable ssl PREFERRED mode for connector accounts-debezium 2023-11-10 19:32:28,319 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Starting streaming 2023-11-10 19:32:28,320 WARN [io.deb.rel.RelationalDatabaseSchema] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) After applying the include/exclude list filters, no changes will be captured. Please check your configuration! 2023-11-10 19:32:28,375 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) GTID set purged on server: b162bddc-8aac-11ec-be1e-42010aa20002:1-26264283 2023-11-10 19:32:28,375 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Attempting to generate a filtered GTID set 2023-11-10 19:32:28,375 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) GTID set from previous recorded offset: b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730 2023-11-10 19:32:28,377 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) GTID set available on server: b162bddc-8aac-11ec-be1e-42010aa20002:1-26762731 2023-11-10 19:32:28,377 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Using first available positions for new GTID channels 2023-11-10 19:32:28,377 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Relevant GTID set available on server: b162bddc-8aac-11ec-be1e-42010aa20002:1-26762731 2023-11-10 19:32:28,379 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Final merged GTID set to use when connecting to MySQL: b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730 2023-11-10 19:32:28,380 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Registering binlog reader with GTID set: b162bddc-8aac-11ec-be1e-42010aa20002:1-26762730 2023-11-10 19:32:28,381 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Skip 0 events on streaming start 2023-11-10 19:32:28,382 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Skip 0 rows on streaming start 2023-11-10 19:32:28,383 INFO [io.deb.uti.Threads] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Creating thread debezium-mysqlconnector-accounts-debezium-binlog-client 2023-11-10 19:32:28,394 INFO [io.deb.uti.Threads] (blc-cloudsql-master-instance:3306) Creating thread debezium-mysqlconnector-accounts-debezium-binlog-client 2023-11-10 19:32:28,448 INFO [com.git.shy.mys.bin.BinaryLogClient] (blc-cloudsql-master-instance:3306) SSL enabled 2023-11-10 19:32:28,466 ERROR [io.deb.pip.ErrorHandler] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Producer failure: io.debezium.DebeziumException: Failed to authenticate to the MySQL database at REDACTED:3306 with user 'debezium' at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.execute(MySqlStreamingChangeEventSource.java:1034) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.execute(MySqlStreamingChangeEventSource.java:92) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: com.github.shyiko.mysql.binlog.network.AuthenticationException: Access denied for user 'debezium'@'REDACTED' (using password: YES) at com.github.shyiko.mysql.binlog.network.Authenticator.readResult(Authenticator.java:85) at com.github.shyiko.mysql.binlog.network.Authenticator.authenticate(Authenticator.java:70) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:574) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932) ... 1 more 2023-11-10 19:32:28,478 WARN [io.deb.pip.ErrorHandler] (debezium-mysqlconnector-accounts-debezium-change-event-source-coordinator) Retry 1 of unlimited retries will be attempted 2023-11-10 19:32:28,483 INFO [io.deb.emb.EmbeddedEngine] (pool-8-thread-1) Stopping the task and engine 2023-11-10 19:32:28,483 INFO [io.deb.con.com.BaseSourceTask] (pool-8-thread-1) Stopping down connector 2023-11-10 19:32:28,487 INFO [io.deb.pip.sig.SignalProcessor] (pool-8-thread-1) SignalProcessor stopped 2023-11-10 19:32:28,492 INFO [io.deb.jdb.JdbcConnection] (pool-12-thread-1) Connection gracefully closed 2023-11-10 19:32:28,494 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-8-thread-1) Stopped FileOffsetBackingStore 2023-11-10 19:32:28,497 ERROR [io.deb.ser.ConnectorLifecycle] (pool-8-thread-1) Connector completed: success = 'false', message = 'Stopping connector after error in the application's handler method: java.net.ConnectException', error = 'java.lang.InterruptedException: java.net.ConnectException': java.lang.InterruptedException: java.net.ConnectException at io.debezium.server.http.HttpChangeConsumer.recordSent(HttpChangeConsumer.java:197) at io.debezium.server.http.HttpChangeConsumer.handleBatch(HttpChangeConsumer.java:164) at io.debezium.embedded.ConvertingEngineBuilder.lambda$notifying$2(ConvertingEngineBuilder.java:101) at io.debezium.embedded.EmbeddedEngine.pollRecords(EmbeddedEngine.java:1008) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:755) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:229) at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:170) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) 2023-11-10 19:32:28,514 INFO [io.deb.ser.DebeziumServer] (main) Received request to stop the engine 2023-11-10 19:32:28,515 INFO [io.deb.emb.EmbeddedEngine] (main) Stopping the embedded engine 2023-11-10 19:32:28,558 INFO [io.quarkus] (main) debezium-server-dist stopped in 0.059s