Bug report

CREATE DEFINER=`root`@`127.0.0.1` TRIGGER IF NOT EXISTS `my_trigger` BEFORE INSERT ON `my_table` FOR EACH ROW BEGIN SET NEW.my_col = CONCAT(NEW.my_col, NEW._id); END

Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 3918
Server version: 8.0.36 Source distributionCopyright (c) 2000, 2024, Oracle and/or its affiliates.Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql> CREATE TABLE `my_table` (
    ->   `_id` INT NOT NULL AUTO_INCREMENT,
    ->   `my_col` VARCHAR(20) DEFAULT NULL,
    ->   PRIMARY KEY (`_id`)
    -> );
Query OK, 0 rows affected (0.09 sec)
mysql> DELIMITER //
mysql> CREATE TRIGGER IF NOT EXISTS `my_trigger` BEFORE INSERT ON `my_table` FOR EACH ROW BEGIN SET NEW.my_col = CONCAT(NEW.my_col, NEW._id); END;//
Query OK, 0 rows affected (0.03 sec)mysql> DELIMITER ;
mysql> 

{"timestamp":"2024-05-17T14:18:25.557+03:00","sequence":2011,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.ConnectorLifecycle","level":"ERROR","message":"Connector completed: success = 'false', message = 'org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.', error = 'org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.'","threadName":"pool-7-thread-1","threadId":43,"mdc":{},"ndc":"","hostName":"t480","processName":"io.debezium.server.Main","processId":6664,"exception":{"refId":1,"exceptionType":"org.apache.kafka.connect.errors.ConnectException","message":"An exception occurred in the change event producer. This connector will be stopped.","frames":[{"class<span class="code-quote">":"io.debezium.pipeline.ErrorHandler","method":"setProducerThrowable","line":67},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":579},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":2,"exceptionType":"io.debezium.DebeziumException","message":"Error processing binlog event","frames":[{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":579},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":3,"exceptionType":"io.debezium.text.ParsingException","message":"DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`127.0.0.1` TRIGGER IF NOT EXISTS `my_trigger` BEFORE INSERT ON `my_table` FOR EACH ROW BEGIN SET NEW.my_col = CONCAT(NEW.my_col, NEW._id); END'\nno viable alternative at input 'CREATE DEFINER=`root`@`127.0.0.1` TRIGGER IF NOT'","frames":[{"class<span class="code-quote">":"io.debezium.antlr.ParsingErrorListener","method":"syntaxError","line":43},{"class<span class="code-quote">":"org.antlr.v4.runtime.ProxyErrorListener","method":"syntaxError","line":41},{"class<span class="code-quote">":"org.antlr.v4.runtime.Parser","method":"notifyErrorListeners","line":543},{"class<span class="code-quote">":"org.antlr.v4.runtime.DefaultErrorStrategy","method":"reportNoViableAlternative","line":310},{"class<span class="code-quote">":"org.antlr.v4.runtime.DefaultErrorStrategy","method":"reportError","line":136},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"sqlStatements","line":1280},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"root","line":996},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":77},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":49},{"class<span class="code-quote">":"io.debezium.antlr.AntlrDdlParser","method":"parse","line":76},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseDdl","line":311},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseStreamingDdl","line":258},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleQueryEvent","line":726},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$5","line":179},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":559},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":4,"exceptionType":"org.antlr.v4.runtime.NoViableAltException","message":null,"frames":[{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"noViableAlt","line":2028},{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"execATN","line":467},{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"adaptivePredict","line":393},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"sqlStatements","line":1072},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"root","line":996},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":77},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":49},{"class<span class="code-quote">":"io.debezium.antlr.AntlrDdlParser","method":"parse","line":76},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseDdl","line":311},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseStreamingDdl","line":258},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleQueryEvent","line":726},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$5","line":179},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":559},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}]}}}}}}}} 

{"timestamp":"2024-05-17T14:18:25.557+03:00","sequence":2011,"loggerClassName":"org.slf4j.impl.Slf4jLogger","loggerName":"io.debezium.server.ConnectorLifecycle","level":"ERROR","message":"Connector completed: success = 'false', message = 'org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.', error = 'org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.'","threadName":"pool-7-thread-1","threadId":43,"mdc":{},"ndc":"","hostName":"t480","processName":"io.debezium.server.Main","processId":6664,"exception":{"refId":1,"exceptionType":"org.apache.kafka.connect.errors.ConnectException","message":"An exception occurred in the change event producer. This connector will be stopped.","frames":[{"class<span class="code-quote">":"io.debezium.pipeline.ErrorHandler","method":"setProducerThrowable","line":67},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":579},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":2,"exceptionType":"io.debezium.DebeziumException","message":"Error processing binlog event","frames":[{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":579},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":3,"exceptionType":"io.debezium.text.ParsingException","message":"DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`127.0.0.1` TRIGGER IF NOT EXISTS `my_trigger` BEFORE INSERT ON `my_table` FOR EACH ROW BEGIN SET NEW.my_col = CONCAT(NEW.my_col, NEW._id); END'\nno viable alternative at input 'CREATE DEFINER=`root`@`127.0.0.1` TRIGGER IF NOT'","frames":[{"class<span class="code-quote">":"io.debezium.antlr.ParsingErrorListener","method":"syntaxError","line":43},{"class<span class="code-quote">":"org.antlr.v4.runtime.ProxyErrorListener","method":"syntaxError","line":41},{"class<span class="code-quote">":"org.antlr.v4.runtime.Parser","method":"notifyErrorListeners","line":543},{"class<span class="code-quote">":"org.antlr.v4.runtime.DefaultErrorStrategy","method":"reportNoViableAlternative","line":310},{"class<span class="code-quote">":"org.antlr.v4.runtime.DefaultErrorStrategy","method":"reportError","line":136},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"sqlStatements","line":1280},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"root","line":996},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":77},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":49},{"class<span class="code-quote">":"io.debezium.antlr.AntlrDdlParser","method":"parse","line":76},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseDdl","line":311},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseStreamingDdl","line":258},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleQueryEvent","line":726},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$5","line":179},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":559},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}],"causedBy":{"exception":{"refId":4,"exceptionType":"org.antlr.v4.runtime.NoViableAltException","message":null,"frames":[{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"noViableAlt","line":2028},{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"execATN","line":467},{"class<span class="code-quote">":"org.antlr.v4.runtime.atn.ParserATNSimulator","method":"adaptivePredict","line":393},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"sqlStatements","line":1072},{"class<span class="code-quote">":"io.debezium.ddl.parser.mysql.generated.MySqlParser","method":"root","line":996},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":77},{"class<span class="code-quote">":"io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser","method":"parseTree","line":49},{"class<span class="code-quote">":"io.debezium.antlr.AntlrDdlParser","method":"parse","line":76},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseDdl","line":311},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogDatabaseSchema","method":"parseStreamingDdl","line":258},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleQueryEvent","line":726},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$5","line":179},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"handleEvent","line":559},{"class<span class="code-quote">":"io.debezium.connector.binlog.BinlogStreamingChangeEventSource","method":"lambda$execute$17","line":209},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"notifyEventListeners","line":1268},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"listenForEventPackets","line":1094},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient","method":"connect","line":653},{"class<span class="code-quote">":"com.github.shyiko.mysql.binlog.BinaryLogClient$7","method":"run","line":954},{"class<span class="code-quote">":"java.lang.Thread","method":"run","line":1570}]}}}}}}}}