Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-9623

MySQL connector does not parse CREATE TABLE

XMLWordPrintable

    • False
    • Hide

      None

      Show
      None
    • 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

       

              Unassigned Unassigned
              ochedru Olivier Chédru (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: