2024-03-06 17:31:11,796 ERROR [io.deb.con.mys.MySqlStreamingChangeEventSource] (my-server.internal:3306) Error during binlog processing. Last offset stored = {transaction_id=null, file=mysql.000257, pos=33482742, gtids=39a0413b-2a07-11ee-bf8a-0022485c4761:1-33094550, server_id=1214007206, event=1}, binlog reader near position = mysql.000257/33482742 2024-03-06 17:31:11,797 ERROR [io.deb.pip.ErrorHandler] (my-server.internal:3306) Producer failure: io.debezium.DebeziumException: Error processing binlog event at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:395) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$27(MySqlStreamingChangeEventSource.java:930) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1246) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1072) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'alter table descriptors modify Description varchar(512) unicode' extraneous input 'unicode' expecting {, '-'} 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.reportUnwantedToken(DefaultErrorStrategy.java:377) at org.antlr.v4.runtime.DefaultErrorStrategy.singleTokenDeletion(DefaultErrorStrategy.java:548) at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:266) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:993) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:46) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:78) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:593) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$15(MySqlStreamingChangeEventSource.java:901) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:375) ... 6 more 2024-03-06 17:31:11,798 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (my-server.internal:3306) 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. 2024-03-06 17:31:12,099 INFO [io.deb.emb.EmbeddedEngine] (pool-9-thread-1) Stopping the task and engine 2024-03-06 17:31:12,103 INFO [io.deb.con.com.BaseSourceTask] (pool-9-thread-1) Stopping down connector Mar 06, 2024 5:31:12 PM com.github.shyiko.mysql.binlog.BinaryLogClient$5 run INFO: threadExecutor is shut down, terminating keepalive thread 2024-03-06 17:31:12,163 INFO [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-my-change-event-source-coordinator) Finished streaming 2024-03-06 17:31:12,164 INFO [io.deb.pip.sig.SignalProcessor] (pool-9-thread-1) SignalProcessor stopped 2024-03-06 17:31:12,166 INFO [io.deb.con.mys.MySqlStreamingChangeEventSource] (my-server.internal:3306) Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, file=mysql.000257, pos=38222182, gtids=39a0413b-2a07-11ee-bf8a-0022485c4761:1-33094550, server_id=1214007206, event=1} 2024-03-06 17:31:12,172 INFO [io.deb.jdb.JdbcConnection] (pool-14-thread-1) Connection gracefully closed 2024-03-06 17:31:12,175 INFO [org.apa.kaf.con.sto.FileOffsetBackingStore] (pool-9-thread-1) Stopped FileOffsetBackingStore 2024-03-06 17:31:12,175 ERROR [io.deb.ser.ConnectorLifecycle] (pool-9-thread-1) Connector completed: success = 'false', message = 'Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector'', error = '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.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:395) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$27(MySqlStreamingChangeEventSource.java:930) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1246) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1072) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932) at java.base/java.lang.Thread.run(Thread.java:829) 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 'alter table descriptors modify Description varchar(512) unicode' extraneous input 'unicode' expecting {, '-'} 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.reportUnwantedToken(DefaultErrorStrategy.java:377) at org.antlr.v4.runtime.DefaultErrorStrategy.singleTokenDeletion(DefaultErrorStrategy.java:548) at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:266) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:993) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:46) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:78) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:199) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:593) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$15(MySqlStreamingChangeEventSource.java:901) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:375) ... 6 more 2024-03-06 17:31:12,187 INFO [io.deb.ser.DebeziumServer] (main) Received request to stop the engine 2024-03-06 17:31:12,188 INFO [io.deb.emb.EmbeddedEngine] (main) Stopping the embedded engine 2024-03-06 17:31:12,262 INFO [io.quarkus] (main) debezium-server-dist stopped in 0.086s