Details
-
Bug
-
Status: Open (View Workflow)
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Exa cdc 0.0.7 isn't to support "create or replace":
Case:
create or replace table t3( |
id int, |
a char(10) |
);
|
Actual result:
CDC fails with stacktrace:
2026-03-20 14:08:53.363 [main] ERROR io.debezium.embedded.async.AsyncEmbeddedEngine - org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. |
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:607) |
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$17(BinlogStreamingChangeEventSource.java:212) |
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 io.debezium.util.Threads$3.lambda$newThread$0(Threads.java:314) |
at java.base/java.lang.Thread.run(Thread.java:1583) |
Caused by: io.debezium.DebeziumException: Error processing binlog event
|
... 8 more |
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create or replace table t3( |
id int, |
a char(10) |
)'
|
no viable alternative at input 'create or replace table' |
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:544) |
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:1266) |
at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:982) |
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:75) |
at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48) |
at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:74) |
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:314) |
at io.debezium.connector.binlog.BinlogDatabaseSchema.parseStreamingDdl(BinlogDatabaseSchema.java:261) |
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleQueryEvent(BinlogStreamingChangeEventSource.java:756) |
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.lambda$execute$5(BinlogStreamingChangeEventSource.java:182) |
at io.debezium.connector.binlog.BinlogStreamingChangeEventSource.handleEvent(BinlogStreamingChangeEventSource.java:587) |
... 7 more |
Caused by: org.antlr.v4.runtime.NoViableAltException
|
at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2014) |
at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:445) |
at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:371) |
at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1058) |
... 16 more |
2026-03-20 14:08:53.364 [main] INFO com.exasol.debezium.engine.sink.Main - EXASOL Engine stopped |