2024-02-19T11:44:43.9251950Z 2024-02-19 11:44:43,828 INFO NotificationsIT|||test| Starting test io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT#testStopSnapshotKafkaSignal [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:44:43.9257835Z 2024-02-19 11:44:43,828 INFO ReadOnlyIncrementalSnapshotIT|||test| Stopping the connector [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:44:43.9261699Z 2024-02-19 11:44:43,850 INFO |||| Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-02-19T11:44:44.1236620Z 2024-02-19 11:44:44,080 INFO |||| Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-02-19T11:44:44.1239554Z 2024-02-19 11:44:44,083 INFO ReadOnlyIncrementalSnapshotIT|||engine| Engine state has changed from 'CREATING' to 'INITIALIZING' [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:44:44.1243383Z 2024-02-19 11:44:44,083 INFO ReadOnlyIncrementalSnapshotIT|||engine| Loading the custom source info struct maker plugin: io.debezium.connector.mysql.MySqlSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2024-02-19T11:44:44.1247320Z 2024-02-19 11:44:44,084 INFO ReadOnlyIncrementalSnapshotIT|||engine| Using io.debezium.connector.mysql.strategy.mariadb.MariaDbConnectorAdapter [io.debezium.connector.mysql.MySqlConnectorConfig] 2024-02-19T11:44:44.1252393Z 2024-02-19 11:44:44,089 INFO ReadOnlyIncrementalSnapshotIT|||engine| Successfully tested connection for jdbc:mariadb://localhost:4302/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL&connectTimeout=30000 with user 'mysqluser' [io.debezium.connector.mysql.MySqlConnector] 2024-02-19T11:44:44.1256088Z 2024-02-19 11:44:44,090 INFO |||| Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-02-19T11:44:44.1258228Z 2024-02-19 11:44:44,090 INFO ReadOnlyIncrementalSnapshotIT|||engine| Engine state has changed from 'INITIALIZING' to 'CREATING_TASKS' [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:44:44.1261277Z 2024-02-19 11:44:44,090 INFO ReadOnlyIncrementalSnapshotIT|||engine| Engine state has changed from 'CREATING_TASKS' to 'STARTING_TASKS' [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:44:44.1263852Z 2024-02-19 11:44:44,092 INFO |||| Starting MySqlConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1266117Z 2024-02-19 11:44:44,092 INFO |||| connector.class = io.debezium.connector.mysql.MySqlConnector [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1268331Z 2024-02-19 11:44:44,092 INFO |||| message.key.columns = incremental_snapshot-test_dqpj8b.a42:pk1,pk2,pk3,pk4 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1270155Z 2024-02-19 11:44:44,092 INFO |||| incremental.snapshot.chunk.size = 1 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1271783Z 2024-02-19 11:44:44,092 INFO |||| record.processing.shutdown.timeout.ms = 1000 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1273386Z 2024-02-19 11:44:44,092 INFO |||| signal.enabled.channels = source,kafka [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1274857Z 2024-02-19 11:44:44,092 INFO |||| include.schema.changes = false [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1276597Z 2024-02-19 11:44:44,092 INFO |||| record.processing.order = ORDERED [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1278074Z 2024-02-19 11:44:44,092 INFO |||| connector.adapter = mariadb [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1280383Z 2024-02-19 11:44:44,092 INFO |||| schema.history.internal.file.filename = /home/runner/work/debezium/debezium/debezium-connector-mysql/target/data/file-schema-history-is.txt [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1282776Z 2024-02-19 11:44:44,092 INFO |||| topic.prefix = is_test [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1283858Z 2024-02-19 11:44:44,092 INFO |||| database.jdbc.driver = org.mariadb.jdbc.Driver [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1285496Z 2024-02-19 11:44:44,092 INFO |||| offset.storage.file.filename = /home/runner/work/debezium/debezium/debezium-connector-mysql/target/data/file-connector-offsets.txt [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1286979Z 2024-02-19 11:44:44,092 INFO |||| poll.interval.ms = 10 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1288153Z 2024-02-19 11:44:44,092 INFO |||| signal.data.collection = incremental_snapshot-test_dqpj8b.debezium_signal [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1289329Z 2024-02-19 11:44:44,092 INFO |||| record.processing.threads = 4 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1290513Z 2024-02-19 11:44:44,092 INFO |||| errors.retry.delay.initial.ms = 300 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1291608Z 2024-02-19 11:44:44,092 INFO |||| binlog.buffer.size = 10000 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1292754Z 2024-02-19 11:44:44,092 INFO |||| value.converter = org.apache.kafka.connect.json.JsonConverter [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1294056Z 2024-02-19 11:44:44,092 INFO |||| key.converter = org.apache.kafka.connect.json.JsonConverter [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1295526Z 2024-02-19 11:44:44,092 INFO |||| database.user = mysqluser [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1297454Z 2024-02-19 11:44:44,092 INFO |||| signal.kafka.bootstrap.servers = localhost:37233 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1299374Z 2024-02-19 11:44:44,092 INFO |||| database.server.id = 18765 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1301621Z 2024-02-19 11:44:44,092 INFO |||| offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1304137Z 2024-02-19 11:44:44,092 INFO |||| signal.kafka.topic = incremental_snapshot-test_dqpj8bsignals_topic [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1306051Z 2024-02-19 11:44:44,092 INFO |||| signal.poll.interval.ms = 1 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1307729Z 2024-02-19 11:44:44,092 INFO |||| read.only = true [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1309295Z 2024-02-19 11:44:44,092 INFO |||| offset.flush.timeout.ms = 5000 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1310992Z 2024-02-19 11:44:44,092 INFO |||| errors.retry.delay.max.ms = 10000 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1313031Z 2024-02-19 11:44:44,092 INFO |||| incremental.snapshot.allow.schema.changes = true [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1314937Z 2024-02-19 11:44:44,092 INFO |||| database.port = 4302 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1316569Z 2024-02-19 11:44:44,092 INFO |||| offset.flush.interval.ms = 0 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1318418Z 2024-02-19 11:44:44,092 INFO |||| database.ssl.mode = disabled [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1320144Z 2024-02-19 11:44:44,092 INFO |||| internal.task.management.timeout.ms = 180000 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1322100Z 2024-02-19 11:44:44,092 INFO |||| database.protocol = jdbc:mariadb [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1324376Z 2024-02-19 11:44:44,092 INFO |||| schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1326774Z 2024-02-19 11:44:44,092 INFO |||| record.processing.with.serial.consumer = false [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1328699Z 2024-02-19 11:44:44,092 INFO |||| table.exclude.list = incremental_snapshot-test_dqpj8b.b [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1330427Z 2024-02-19 11:44:44,092 INFO |||| errors.max.retries = -1 [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1332201Z 2024-02-19 11:44:44,092 INFO |||| database.hostname = localhost [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1333947Z 2024-02-19 11:44:44,092 INFO |||| database.password = ******** [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1335930Z 2024-02-19 11:44:44,092 INFO |||| schema.name.adjustment.mode = avro [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1337959Z 2024-02-19 11:44:44,092 INFO |||| name = testing-connector [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1339840Z 2024-02-19 11:44:44,092 INFO |||| include.query = true [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1341563Z 2024-02-19 11:44:44,092 INFO |||| snapshot.mode = schema_only [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1343536Z 2024-02-19 11:44:44,092 INFO |||| database.include.list = incremental_snapshot-test_dqpj8b [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1346268Z 2024-02-19 11:44:44,092 INFO |||| Loading the custom source info struct maker plugin: io.debezium.connector.mysql.MySqlSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2024-02-19T11:44:44.1349201Z 2024-02-19 11:44:44,093 INFO |||| Using io.debezium.connector.mysql.strategy.mariadb.MariaDbConnectorAdapter [io.debezium.connector.mysql.MySqlConnectorConfig] 2024-02-19T11:44:44.1352108Z 2024-02-19 11:44:44,093 INFO |||| Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy [io.debezium.config.CommonConnectorConfig] 2024-02-19T11:44:44.1354419Z 2024-02-19 11:44:44,093 INFO |||| No previous offsets found [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:44:44.1356399Z 2024-02-19 11:44:44,104 INFO |||| Closing connection before starting schema recovery [io.debezium.connector.mysql.MySqlConnectorTask] 2024-02-19T11:44:44.1358250Z 2024-02-19 11:44:44,105 INFO |||| Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-02-19T11:44:44.1360737Z 2024-02-19 11:44:44,105 INFO |||| Connector started for the first time, database schema history recovery will not be executed [io.debezium.connector.mysql.MySqlConnectorTask] 2024-02-19T11:44:44.1363173Z 2024-02-19 11:44:44,105 INFO |||| Reconnecting after finishing schema recovery [io.debezium.connector.mysql.MySqlConnectorTask] 2024-02-19T11:44:44.1365055Z 2024-02-19 11:44:44,107 INFO |||| No previous offset found [io.debezium.connector.mysql.MySqlConnectorTask] 2024-02-19T11:44:44.1367180Z 2024-02-19 11:44:44,108 INFO |||| Requested thread factory for connector MySqlConnector, id = is_test named = SignalProcessor [io.debezium.util.Threads] 2024-02-19T11:44:44.2238443Z 2024-02-19 11:44:44,146 INFO |||| Subscribing to signals topic 'incremental_snapshot-test_dqpj8bsignals_topic' [io.debezium.pipeline.signal.channels.KafkaSignalChannel] 2024-02-19T11:44:44.2241776Z 2024-02-19 11:44:44,148 INFO |||| Requested thread factory for connector MySqlConnector, id = is_test named = change-event-source-coordinator [io.debezium.util.Threads] 2024-02-19T11:44:44.2244311Z 2024-02-19 11:44:44,148 INFO |||| Requested thread factory for connector MySqlConnector, id = is_test named = blocking-snapshot [io.debezium.util.Threads] 2024-02-19T11:44:44.2246624Z 2024-02-19 11:44:44,148 INFO |||| Creating thread debezium-mysqlconnector-is_test-change-event-source-coordinator [io.debezium.util.Threads] 2024-02-19T11:44:44.2249275Z 2024-02-19 11:44:44,149 INFO ReadOnlyIncrementalSnapshotIT|||engine| Engine state has changed from 'STARTING_TASKS' to 'POLLING_TASKS' [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:44:44.2252398Z 2024-02-19 11:44:44,149 INFO ReadOnlyIncrementalSnapshotIT|||engine| Using io.debezium.embedded.async.ParallelSmtConsumerProcessor processor [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:44:44.2255435Z 2024-02-19 11:44:44,195 INFO MySQL|is_test|0|snapshot| Read binlog position of MariaDB primary server [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnectorAdapter] 2024-02-19T11:44:44.2258524Z 2024-02-19 11:44:44,196 INFO MySQL|is_test|0|snapshot| using binlog 'mysql-bin.000002' at position '18273677' and gtid '0-112233-16775' [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnectorAdapter] 2024-02-19T11:44:45.3910164Z 11:44:45.390 mysql-gtids2024-02-19 0:44:45 1676 [Note] Start binlog_dump to slave_server(18765), pos(, 0), using_gtid(1), gtid('0-112233-16775') 2024-02-19T11:44:45.4336115Z Feb 19, 2024 11:44:45 AM com.github.shyiko.mysql.binlog.BinaryLogClient requestBinaryLogStreamMaria 2024-02-19T11:44:45.4339433Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4341860Z INFO: 0-112233-16775 2024-02-19T11:44:45.4342586Z Feb 19, 2024 11:44:45 AM com.github.shyiko.mysql.binlog.BinaryLogClient connect 2024-02-19T11:44:45.4343757Z INFO: Connected to localhost:4302 at 0-112233-16775 (sid:18765, cid:1676) 2024-02-19T11:44:45.4346636Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4351935Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4356768Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a4.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a4.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4361455Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a4.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a4.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4366136Z 2024-02-19 11:44:45,377 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a4.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a4.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4371155Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a42.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a42.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4375872Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a42.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a42.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4380545Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a42.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a42.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4385231Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_date.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_date.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4389995Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_date.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_date.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4394733Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_date.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_date.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4399724Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_dt.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_dt.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4404527Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_dt.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_dt.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4409226Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.a_dt.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.a_dt.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4413837Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.c.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.c.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4418435Z 2024-02-19 11:44:45,378 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.c.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.c.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4423058Z 2024-02-19 11:44:45,379 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.c.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.c.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4427875Z 2024-02-19 11:44:45,379 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.debezium_signal.Value' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.debezium_signal.Value' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4524525Z 2024-02-19 11:44:45,379 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.debezium_signal.Key' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.debezium_signal.Key' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4529386Z 2024-02-19 11:44:45,379 WARN MySQL|is_test|0|snapshot| The Kafka Connect schema name 'is_test.incremental_snapshot-test_dqpj8b.debezium_signal.Envelope' is not a valid Avro schema name, so replacing with 'is_test.incremental_snapshot_test_dqpj8b.debezium_signal.Envelope' [io.debezium.schema.SchemaNameAdjuster] 2024-02-19T11:44:45.4532892Z 2024-02-19 11:44:45,379 INFO MySQL|is_test|0|snapshot| Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2024-02-19T11:44:45.4535187Z 2024-02-19 11:44:45,379 INFO MySQL|is_test|0|snapshot| Snapshot completed [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2024-02-19T11:44:45.4537665Z 2024-02-19 11:44:45,380 INFO MySQL|is_test|0|streaming| Requested thread factory for connector MySqlConnector, id = is_test named = binlog-client [io.debezium.util.Threads] 2024-02-19T11:44:45.4540865Z 2024-02-19 11:44:45,385 INFO MySQL|is_test|0|streaming| No incremental snapshot in progress, no action needed on start [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:44:45.4543874Z 2024-02-19 11:44:45,385 INFO MySQL|is_test|0|streaming| SignalProcessor started. Scheduling it every 1ms [io.debezium.pipeline.signal.SignalProcessor] 2024-02-19T11:44:45.4546348Z 2024-02-19 11:44:45,385 INFO MySQL|is_test|0|streaming| Creating thread debezium-mysqlconnector-is_test-SignalProcessor [io.debezium.util.Threads] 2024-02-19T11:44:45.4548798Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| GTID set purged on server: '' [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.4551320Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| Attempting to generate a filtered GTID set [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4554070Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| GTID set from previous recorded offset: 0-112233-16775 [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4556785Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| GTID set available on server: 0-112233-16775 [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4559522Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| Using first available positions for new GTID channels [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4562501Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| Relevant GTID set available on server: 0-112233-16775 [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4565447Z 2024-02-19 11:44:45,386 INFO MySQL|is_test|0|streaming| Final merged GTID set to use when connecting to MariaDB: 0-112233-16775 [io.debezium.connector.mysql.strategy.mariadb.MariaDbConnection] 2024-02-19T11:44:45.4568351Z 2024-02-19 11:44:45,387 INFO MySQL|is_test|0|streaming| Registering binlog reader with GTID set: '0-112233-16775' [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.4570934Z 2024-02-19 11:44:45,387 INFO MySQL|is_test|0|streaming| Skip 0 events on streaming start [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.4573329Z 2024-02-19 11:44:45,387 INFO MySQL|is_test|0|streaming| Skip 0 rows on streaming start [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.4575653Z 2024-02-19 11:44:45,387 INFO MySQL|is_test|0|streaming| Creating thread debezium-mysqlconnector-is_test-binlog-client [io.debezium.util.Threads] 2024-02-19T11:44:45.4577732Z 2024-02-19 11:44:45,387 INFO |||| Creating thread debezium-mysqlconnector-is_test-binlog-client [io.debezium.util.Threads] 2024-02-19T11:44:45.4588206Z 2024-02-19 11:44:45,393 INFO MySQL|is_test||binlog| Connected to binlog at localhost:4302, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-bin.000002, currentBinlogPosition=18273677, currentRowNumber=0, serverId=0, sourceTime=2024-02-19T11:44:45.379Z, threadId=-1, currentQuery=null, tableIds=[incremental_snapshot-test_dqpj8b.debezium_signal], databaseName=year_test_q8n3vm], snapshotCompleted=true, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=0-112233-16775, currentGtidSet=0-112233-16775, restartBinlogFilename=mysql-bin.000002, restartBinlogPosition=18273677, restartRowsToSkip=0, restartEventsToSkip=0, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]] [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.4597927Z 2024-02-19 11:44:45,393 INFO MySQL|is_test||binlog| Creating thread debezium-mysqlconnector-is_test-binlog-client [io.debezium.util.Threads] 2024-02-19T11:44:45.4600320Z 2024-02-19 11:44:45,393 INFO MySQL|is_test|0|streaming| Waiting for keepalive thread to start [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:45.5325392Z 2024-02-19 11:44:45,493 INFO MySQL|is_test|0|streaming| Keepalive thread is running [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:44:50.3361811Z 2024-02-19 11:44:50,305 INFO |||| Requested 'INCREMENTAL' snapshot of data collections '[incremental_snapshot-test_dqpj8b.a]' with additional conditions '[]' and surrogate key 'PK of table will be used' [io.debezium.pipeline.signal.actions.snapshotting.ExecuteSnapshot] 2024-02-19T11:45:33.4703669Z 2024-02-19 11:45:33,434 INFO MySQL|is_test||binlog| Incremental snapshot's schema verification passed = true, schema = columns: { 2024-02-19T11:45:33.4735107Z pk INTEGER(11, 0) NOT NULL 2024-02-19T11:45:33.4736052Z aa INTEGER(11, 0) DEFAULT VALUE NULL 2024-02-19T11:45:33.4736849Z } 2024-02-19T11:45:33.4737208Z primary key: [] 2024-02-19T11:45:33.4793544Z default charset: null 2024-02-19T11:45:33.4794548Z comment: null 2024-02-19T11:45:33.4794972Z attributes: { 2024-02-19T11:45:33.4795345Z } 2024-02-19T11:45:33.4796138Z [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext] 2024-02-19T11:45:33.4798800Z 2024-02-19 11:45:33,435 INFO MySQL|is_test||binlog| Incremental snapshot for table 'incremental_snapshot-test_dqpj8b.a' will end at position [1000] [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:45:33.4817431Z 2024-02-19 11:45:33,441 INFO |||| 3 records sent during previous 00:00:49.35, last recorded offset of {server=is_test} partition is {incremental_snapshot_correlation_id=null, ts_sec=1708343133, file=mysql-bin.000002, pos=18273677, incremental_snapshot_signal_offset=0, incremental_snapshot_maximum_key=aced0005757200135b4c6a6176612e6c616e672e4f626a6563743b90ce589f1073296c020000787000000001737200116a6176612e6c616e672e496e746567657212e2a0a4f781873802000149000576616c7565787200106a6176612e6c616e672e4e756d62657286ac951d0b94e08b0200007870000003e8, gtids=0-112233-16775, server_id=112233, incremental_snapshot_collections=[{"incremental_snapshot_collections_id":"incremental_snapshot-test_dqpj8b.a","incremental_snapshot_collections_additional_condition":null,"incremental_snapshot_collections_surrogate_key":null}], incremental_snapshot_primary_key=aced0005757200135b4c6a6176612e6c616e672e4f626a6563743b90ce589f1073296c020000787000000001737200116a6176612e6c616e672e496e746567657212e2a0a4f781873802000149000576616c7565787200106a6176612e6c616e672e4e756d62657286ac951d0b94e08b020000787000000003} [io.debezium.connector.common.BaseSourceTask] 2024-02-19T11:45:33.4824302Z 2024-02-19 11:45:33,467 INFO |||| Requested stop of snapshot 'INCREMENTAL' for data collections '[incremental_snapshot-test_dqpj8b.a]' [io.debezium.pipeline.signal.actions.snapshotting.StopSnapshot] 2024-02-19T11:45:33.4826291Z 2024-02-19 11:45:33,468 INFO |||| Removing '[incremental_snapshot-test_dqpj8b.a]' collections from incremental snapshot [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:45:33.4828703Z 2024-02-19 11:45:33,468 INFO |||| Removed 'incremental_snapshot-test_dqpj8b.a' from incremental snapshot collection list. [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:45:33.4830768Z 2024-02-19 11:45:33,468 INFO |||| Advancing to next available collection in the incremental snapshot. [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:45:33.4833010Z 2024-02-19 11:45:33,468 INFO MySQL|is_test||binlog| No data returned by the query, incremental snapshotting of table 'incremental_snapshot-test_dqpj8b.a' finished [io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource] 2024-02-19T11:45:33.4835902Z 2024-02-19 11:45:33,468 ERROR MySQL|is_test||binlog| Error during binlog processing. Last offset stored = {ts_sec=1708343085, file=mysql-bin.000002, pos=18273677, incremental_snapshot_signal_offset=null, gtids=0-112233-16775, server_id=112233, event=1}, binlog reader near position = mysql-bin.000002/18273677 [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:45:33.4838330Z 2024-02-19 11:45:33,468 ERROR MySQL|is_test||binlog| Producer failure [io.debezium.pipeline.ErrorHandler] 2024-02-19T11:45:33.4839098Z io.debezium.DebeziumException: Error processing binlog event 2024-02-19T11:45:33.4839956Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:305) 2024-02-19T11:45:33.4841151Z at io.debezium.connector.mysql.EventBuffer.consumeEvent(EventBuffer.java:178) 2024-02-19T11:45:33.4841838Z at io.debezium.connector.mysql.EventBuffer.add(EventBuffer.java:124) 2024-02-19T11:45:33.4842753Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$31(MySqlStreamingChangeEventSource.java:888) 2024-02-19T11:45:33.4843815Z at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263) 2024-02-19T11:45:33.4844767Z at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089) 2024-02-19T11:45:33.4845652Z at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648) 2024-02-19T11:45:33.4846425Z at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949) 2024-02-19T11:45:33.4847017Z at java.base/java.lang.Thread.run(Thread.java:840) 2024-02-19T11:45:33.4847895Z Caused by: io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'null' 2024-02-19T11:45:33.4849363Z at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:418) 2024-02-19T11:45:33.4851223Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.readUntilGtidChange(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:129) 2024-02-19T11:45:33.4853180Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.processHeartbeat(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:121) 2024-02-19T11:45:33.4855109Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.processHeartbeat(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:83) 2024-02-19T11:45:33.4856523Z at io.debezium.pipeline.EventDispatcher.dispatchServerHeartbeatEvent(EventDispatcher.java:441) 2024-02-19T11:45:33.4857875Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleServerHeartbeat(MySqlStreamingChangeEventSource.java:347) 2024-02-19T11:45:33.4859245Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:850) 2024-02-19T11:45:33.4860405Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:285) 2024-02-19T11:45:33.4861137Z ... 8 common frames omitted 2024-02-19T11:45:33.4862605Z Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.pipeline.source.snapshot.incremental.DataCollection.getId()" because the return value of "io.debezium.pipeline.source.snapshot.incremental.IncrementalSnapshotContext.currentDataCollectionId()" is null 2024-02-19T11:45:33.4864724Z at io.debezium.pipeline.notification.IncrementalSnapshotNotificationService.notifyTableScanCompleted(IncrementalSnapshotNotificationService.java:108) 2024-02-19T11:45:33.4866384Z at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:397) 2024-02-19T11:45:33.4867395Z ... 15 common frames omitted 2024-02-19T11:45:33.4869128Z 2024-02-19 11:45:33,468 INFO MySQL|is_test||binlog| Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2024-02-19T11:45:33.5704673Z 2024-02-19 11:45:33,474 ERROR ReadOnlyIncrementalSnapshotIT|||engine| Engine has failed with [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:45:33.5709895Z java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. 2024-02-19T11:45:33.5711856Z at java.base/java.util.concurrent.FutureTask.report(FutureTask.java:122) 2024-02-19T11:45:33.5712961Z at java.base/java.util.concurrent.FutureTask.get(FutureTask.java:191) 2024-02-19T11:45:33.5714307Z at io.debezium.embedded.async.AsyncEmbeddedEngine.runTasksPolling(AsyncEmbeddedEngine.java:454) 2024-02-19T11:45:33.5715757Z at io.debezium.embedded.async.AsyncEmbeddedEngine.run(AsyncEmbeddedEngine.java:204) 2024-02-19T11:45:33.5717451Z at io.debezium.embedded.async.TestingAsyncEmbeddedEngine.run(TestingAsyncEmbeddedEngine.java:27) 2024-02-19T11:45:33.5719355Z at io.debezium.embedded.AbstractConnectorTest.lambda$start$8(AbstractConnectorTest.java:423) 2024-02-19T11:45:33.5721078Z at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) 2024-02-19T11:45:33.5722535Z at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) 2024-02-19T11:45:33.5723502Z at java.base/java.lang.Thread.run(Thread.java:840) 2024-02-19T11:45:33.5725163Z Caused by: org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. 2024-02-19T11:45:33.5727016Z at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) 2024-02-19T11:45:33.5729239Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:305) 2024-02-19T11:45:33.5730813Z at io.debezium.connector.mysql.EventBuffer.consumeEvent(EventBuffer.java:178) 2024-02-19T11:45:33.5731980Z at io.debezium.connector.mysql.EventBuffer.add(EventBuffer.java:124) 2024-02-19T11:45:33.5733441Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$31(MySqlStreamingChangeEventSource.java:888) 2024-02-19T11:45:33.5735324Z at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263) 2024-02-19T11:45:33.5737001Z at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089) 2024-02-19T11:45:33.5738543Z at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648) 2024-02-19T11:45:33.5739917Z at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949) 2024-02-19T11:45:33.5741114Z ... 1 common frames omitted 2024-02-19T11:45:33.5741918Z Caused by: io.debezium.DebeziumException: Error processing binlog event 2024-02-19T11:45:33.5744541Z ... 9 common frames omitted 2024-02-19T11:45:33.5745789Z Caused by: io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'null' 2024-02-19T11:45:33.5748042Z at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:418) 2024-02-19T11:45:33.5751085Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.readUntilGtidChange(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:129) 2024-02-19T11:45:33.5753928Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.processHeartbeat(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:121) 2024-02-19T11:45:33.5756165Z at io.debezium.connector.mysql.strategy.mariadb.MariaDbReadOnlyIncrementalSnapshotChangeEventSource.processHeartbeat(MariaDbReadOnlyIncrementalSnapshotChangeEventSource.java:83) 2024-02-19T11:45:33.5757596Z at io.debezium.pipeline.EventDispatcher.dispatchServerHeartbeatEvent(EventDispatcher.java:441) 2024-02-19T11:45:33.5758871Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleServerHeartbeat(MySqlStreamingChangeEventSource.java:347) 2024-02-19T11:45:33.5760754Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:850) 2024-02-19T11:45:33.5762992Z at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:285) 2024-02-19T11:45:33.5763997Z ... 8 common frames omitted 2024-02-19T11:45:33.5765701Z Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.pipeline.source.snapshot.incremental.DataCollection.getId()" because the return value of "io.debezium.pipeline.source.snapshot.incremental.IncrementalSnapshotContext.currentDataCollectionId()" is null 2024-02-19T11:45:33.5767929Z at io.debezium.pipeline.notification.IncrementalSnapshotNotificationService.notifyTableScanCompleted(IncrementalSnapshotNotificationService.java:108) 2024-02-19T11:45:33.5769661Z at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:397) 2024-02-19T11:45:33.5770770Z ... 15 common frames omitted 2024-02-19T11:45:33.5771865Z 2024-02-19 11:45:33,474 INFO ReadOnlyIncrementalSnapshotIT|||engine| Engine state has changed from 'POLLING_TASKS' to 'STOPPING' [io.debezium.embedded.async.AsyncEmbeddedEngine] 2024-02-19T11:45:33.5773403Z 2024-02-19 11:45:33,563 INFO ReadOnlyIncrementalSnapshotIT|||test| Stopping the connector [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:45:33.5774808Z 2024-02-19 11:45:33,563 INFO ReadOnlyIncrementalSnapshotIT|||test| Stopping the engine [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:45:33.5776210Z 2024-02-19 11:45:33,566 INFO ReadOnlyIncrementalSnapshotIT|||test| Stopping the connector [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:45:33.5777619Z 2024-02-19 11:45:33,566 INFO ReadOnlyIncrementalSnapshotIT|||test| Stopping the connector [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT] 2024-02-19T11:45:33.5780548Z 2024-02-19 11:45:33,567 INFO ReadOnlyIncrementalSnapshotIT|||test| Test io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT#testStopSnapshotKafkaSignal failed [io.debezium.connector.mysql.ReadOnlyIncrementalSnapshotIT]