io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`system_user`@`%` PROCEDURE `update_order`(IN orderID bigint(11)) BEGIN insert into order_config(order_id, attribute, value, performer) SELECT orderID, 'first_attr', 'true', 'AppConfig' WHERE NOT EXISTS (select 1 from inventory.order_config t1 where t1.order_id = orderID and t1.attribute = 'first_attr') OR EXISTS (select 1 from inventory.order_config p2 where p2.order_id = orderID and p2.attribute = 'first_attr' and p2.performer = 'AppConfig') ON DUPLICATE KEY UPDATE value = 'true', performer = 'AppConfig'; -- Enable second_attr for order insert into order_config(order_id, attribute, value, performer) select orderID, 'second_attr', 'true', 'AppConfig' WHERE NOT EXISTS (select 1 from inventory.order_config t1 where t1.order_id = orderID and t1.attribute = 'second_attr') OR EXISTS (select 1 from inventory.order_config p2 where p2.order_id = orderID and p2.attribute = 'second_attr' and p2.performer = 'AppConfig') ON DUPLICATE KEY UPDATE value = 'true', performer = 'AppConfig'; -- Disable third_attr INSERT INTO order_config (order_id, attribute, value, customer_conf, is_large, type, performer) select orderID, 'third_attr', 'false', 1, 0, 3, 'AppConfig' WHERE NOT EXISTS (select 1 from inventory.order_config t1 where t1.order_id = orderID and t1.attribute = 'third_attr') OR EXISTS (select 1 from inventory.order_config p2 where p2.order_id = orderID and p2.attribute = 'third_attr' and p2.performer = 'AppConfig') ON DUPLICATE KEY UPDATE value = 'false', customer_conf = 1, type = 3, is_large = 0, performer = 'AppConfig'; END' mismatched input 'insert' expecting {, '--'} at io.debezium.antlr.AntlrDdlParser.throwParsingException(AntlrDdlParser.java:368) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:95) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:216) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:202) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:573) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$14(MySqlStreamingChangeEventSource.java:827) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:349) ... 6 more