-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
-
False
Looks like the name of the table ("CYCLE") is a reserved keyword. However, MySQL does accept this DDL.
What Debezium connector do you use and what version?
3.3.1.Final
What is the connector configuration?
KafkaConnect
What is the captured database version and mode of deployment?
Azure MySQL 8.0.42
What behavior do you expect?
CREATE TABLE statement should be parsed
What behavior do you see?
2025-10-26 19:01:01 ERROR [task-thread-debezium-x-0] WorkerTask:251 - WorkerSourceTask{id=debezium-x-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted
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) ~[debezium-core-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:595) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$17(BinlogStreamingChangeEventSource.java:210) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1281) ~[mysql-binlog-connector-java-0.40.2.jar:0.40.2]
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1103) ~[mysql-binlog-connector-java-0.40.2.jar:0.40.2]
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:657) ~[mysql-binlog-connector-java-0.40.2.jar:0.40.2]
at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:959) ~[mysql-binlog-connector-java-0.40.2.jar:0.40.2]
at java.base/java.lang.Thread.run(Thread.java:840) [?:?]
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 CYCLE (ID_CYCLE INT DEFAULT 0 NOT NULL,CYC_Titre VARCHAR(255) DEFAULT '',CYC_EstModele BIT DEFAULT 0,CYC_DateModification DATETIME DEFAULT NULL, CONSTRAINT PrimaryKey_CYCLE PRIMARY KEY (ID_CYCLE ASC))'
no viable alternative at input 'CREATE TABLE CYCLE'
at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1266) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:982) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:75) ~[debezium-connector-mysql-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48) ~[debezium-connector-mysql-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:73) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:313) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseStreamingDdl(BinlogDatabaseSchema.java:260) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleQueryEvent(BinlogStreamingChangeEventSource.java:744) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$5(BinlogStreamingChangeEventSource.java:180) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:575) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
... 6 more
Caused by: org.antlr.v4.runtime.NoViableAltException
at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2028) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393) ~[antlr4-runtime-4.10.1.jar:4.10.1]
at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1058) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:982) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:75) ~[debezium-connector-mysql-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48) ~[debezium-connector-mysql-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:73) ~[debezium-ddl-parser-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:313) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseStreamingDdl(BinlogDatabaseSchema.java:260) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleQueryEvent(BinlogStreamingChangeEventSource.java:744) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$5(BinlogStreamingChangeEventSource.java:180) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:575) ~[debezium-connector-binlog-3.3.1.Final.jar:3.3.1.Final]
... 6 more
- links to
-
RHBA-2025:156829
Red Hat build of Debezium 3.2.5 release