[2025-05-29 10:35:25,518] ERROR [codc-rp-25-console-connector|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:52)
io.debezium.DebeziumException: Error processing binlog event
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:591)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$17(BinlogStreamingChangeEventSource.java:209)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1281)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1103)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:657)
    at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:959)
    at java.base/java.lang.Thread.run(Unknown Source)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE IF NOT EXISTS PERCONA_SCHEMA.xtrabackup_history(uuid VARCHAR(40) NOT NULL PRIMARY KEY,name VARCHAR(255) DEFAULT NULL,tool_name VARCHAR(255) DEFAULT NULL,tool_command TEXT DEFAULT NULL,tool_version VARCHAR(255) DEFAULT NULL,ibbackup_version VARCHAR(255) DEFAULT NULL,server_version VARCHAR(255) DEFAULT NULL,start_time TIMESTAMP NULL DEFAULT NULL,end_time TIMESTAMP NULL DEFAULT NULL,lock_time BIGINT UNSIGNED DEFAULT NULL,binlog_pos VARCHAR(128) DEFAULT NULL,innodb_from_lsn BIGINT UNSIGNED DEFAULT NULL,innodb_to_lsn BIGINT UNSIGNED DEFAULT NULL,partial ENUM('Y', 'N') DEFAULT NULL,incremental ENUM('Y', 'N') DEFAULT NULL,format ENUM('file', 'tar', 'xbstream') DEFAULT NULL,compact ENUM('Y', 'N') DEFAULT NULL,compressed ENUM('Y', 'N') DEFAULT NULL,encrypted ENUM('Y', 'N') DEFAULT NULL) CHARACTER SET utf8 ENGINE=innodb'
no viable alternative at input 'CREATE TABLE IF NOT EXISTS PERCONA_SCHEMA.xtrabackup_history(uuid VARCHAR(40) NOT NULL PRIMARY KEY,name VARCHAR(255) DEFAULT NULL,tool_name VARCHAR(255) DEFAULT NULL,tool_command TEXT DEFAULT NULL,tool_version VARCHAR(255) DEFAULT NULL,ibbackup_version VARCHAR(255) DEFAULT NULL,server_version VARCHAR(255) DEFAULT NULL,start_time TIMESTAMP NULL DEFAULT NULL,end_time TIMESTAMP NULL DEFAULT NULL,lock_time BIGINT UNSIGNED DEFAULT NULL,binlog_pos VARCHAR(128) DEFAULT NULL,innodb_from_lsn BIGINT UNSIGNED DEFAULT NULL,innodb_to_lsn BIGINT UNSIGNED DEFAULT NULL,partial ENUM('Y', 'N') DEFAULT NULL,incremental ENUM('Y', 'N') DEFAULT NULL,format ENUM('file', 'tar', 'xbstream') DEFAULT NULL,compact ENUM('Y', 'N') DEFAULT NULL,compressed ENUM('Y', 'N') DEFAULT NULL,encrypted ENUM'
    at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
    at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
    at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543)
    at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310)
    at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1264)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:980)
    at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74)
    at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48)
    at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:76)
    at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:311)
    at io.debezium.connector.binlog.BinlogDatabaseSchema.parseStreamingDdl(BinlogDatabaseSchema.java:258)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleQueryEvent(BinlogStreamingChangeEventSource.java:738)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$5(BinlogStreamingChangeEventSource.java:179)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:571)
    ... 6 more
Caused by: org.antlr.v4.runtime.NoViableAltException
    at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2028)
    at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
    at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1056)
    ... 15 more
[2025-05-29 10:35:25,518] INFO [codc-rp-25-console-connector|task-0] Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. (io.debezium.connector.binlog.BinlogStreamingChangeEventSource:596)
[2025-05-29 10:35:25,571] INFO [codc-rp-25-console-connector|task-0] Keepalive thread is running (io.debezium.connector.binlog.BinlogStreamingChangeEventSource:306)
[2025-05-29 10:35:25,861] ERROR [codc-rp-25-console-connector|task-0] WorkerSourceTask{id=codc-rp-25-console-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:234)
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
    at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:591)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$17(BinlogStreamingChangeEventSource.java:209)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1281)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1103)
    at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:657)
    at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:959)
    at java.base/java.lang.Thread.run(Unknown Source)
Caused by: io.debezium.DebeziumException: Error processing binlog event
    ... 7 more
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE IF NOT EXISTS PERCONA_SCHEMA.xtrabackup_history(uuid VARCHAR(40) NOT NULL PRIMARY KEY,name VARCHAR(255) DEFAULT NULL,tool_name VARCHAR(255) DEFAULT NULL,tool_command TEXT DEFAULT NULL,tool_version VARCHAR(255) DEFAULT NULL,ibbackup_version VARCHAR(255) DEFAULT NULL,server_version VARCHAR(255) DEFAULT NULL,start_time TIMESTAMP NULL DEFAULT NULL,end_time TIMESTAMP NULL DEFAULT NULL,lock_time BIGINT UNSIGNED DEFAULT NULL,binlog_pos VARCHAR(128) DEFAULT NULL,innodb_from_lsn BIGINT UNSIGNED DEFAULT NULL,innodb_to_lsn BIGINT UNSIGNED DEFAULT NULL,partial ENUM('Y', 'N') DEFAULT NULL,incremental ENUM('Y', 'N') DEFAULT NULL,format ENUM('file', 'tar', 'xbstream') DEFAULT NULL,compact ENUM('Y', 'N') DEFAULT NULL,compressed ENUM('Y', 'N') DEFAULT NULL,encrypted ENUM('Y', 'N') DEFAULT NULL) CHARACTER SET utf8 ENGINE=innodb'
no viable alternative at input 'CREATE TABLE IF NOT EXISTS PERCONA_SCHEMA.xtrabackup_history(uuid VARCHAR(40) NOT NULL PRIMARY KEY,name VARCHAR(255) DEFAULT NULL,tool_name VARCHAR(255) DEFAULT NULL,tool_command TEXT DEFAULT NULL,tool_version VARCHAR(255) DEFAULT NULL,ibbackup_version VARCHAR(255) DEFAULT NULL,server_version VARCHAR(255) DEFAULT NULL,start_time TIMESTAMP NULL DEFAULT NULL,end_time TIMESTAMP NULL DEFAULT NULL,lock_time BIGINT UNSIGNED DEFAULT NULL,binlog_pos VARCHAR(128) DEFAULT NULL,innodb_from_lsn BIGINT UNSIGNED DEFAULT NULL,innodb_to_lsn BIGINT UNSIGNED DEFAULT NULL,partial ENUM('Y', 'N') DEFAULT NULL,incremental ENUM('Y', 'N') DEFAULT NULL,format ENUM('file', 'tar', 'xbstream') DEFAULT NULL,compact ENUM('Y', 'N') DEFAULT NULL,compressed ENUM('Y', 'N') DEFAULT NULL,encrypted ENUM'
    at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
    at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
    at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543)
    at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310)
    at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1264)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:980)
    at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74)
    at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48)
    at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:76)
    at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:311)
    at io.debezium.connector.binlog.BinlogDatabaseSchema.parseStreamingDdl(BinlogDatabaseSchema.java:258)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleQueryEvent(BinlogStreamingChangeEventSource.java:738)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$5(BinlogStreamingChangeEventSource.java:179)
    at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:571)
    ... 6 more
Caused by: org.antlr.v4.runtime.NoViableAltException
    at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2028)
    at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
    at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
    at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1056)
    ... 15 more