[2021-02-02 14:51:56,311] ERROR Failed due to error: Error processing binlog event (io.debezium.connector.mysql.BinlogReader:219)
org.apache.kafka.connect.errors.ConnectException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1
    DETERMINISTIC
BEGIN

DECLARE retGUID char(32);

set retGUID = replace(uuid(),'-','');


insert into sql_log values(retGUID,log_type,log_text,0,0,current_user(),now());

return retGUID;

END'
no viable alternative at input 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1\n    DETERMINISTIC\nBEGIN\n\nDECLARE retGUID char(32);\n\nset retGUID = replace(uuid(),'-','');\n\n\ninsert into sql_log values(retGUID,log_type,log_text,0,0,current_user('
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839)
	at java.lang.Thread.run(Thread.java:748)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1
    DETERMINISTIC
BEGIN

DECLARE retGUID char(32);

set retGUID = replace(uuid(),'-','');


insert into sql_log values(retGUID,log_type,log_text,0,0,current_user(),now());

return retGUID;

END'
no viable alternative at input 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1\n    DETERMINISTIC\nBEGIN\n\nDECLARE retGUID char(32);\n\nset retGUID = replace(uuid(),'-','');\n\n\ninsert into sql_log values(retGUID,log_type,log_text,0,0,current_user('
	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:1157)
	at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:885)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
	at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80)
	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:326)
	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:810)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590)
	... 5 more
Caused by: org.antlr.v4.runtime.NoViableAltException
	at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026)
	at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
	at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
	at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:959)
	... 12 more
[2021-02-02 14:51:56,312] INFO 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. (io.debezium.connector.mysql.BinlogReader:612)
[2021-02-02 14:51:56,735] INFO WorkerSourceTask{id=iready_dbz-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:328)
[2021-02-02 14:51:56,736] INFO WorkerSourceTask{id=iready_dbz-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:345)
[2021-02-02 14:51:56,736] ERROR WorkerSourceTask{id=iready_dbz-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:172)
org.apache.kafka.connect.errors.ConnectException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1
    DETERMINISTIC
BEGIN

DECLARE retGUID char(32);

set retGUID = replace(uuid(),'-','');


insert into sql_log values(retGUID,log_type,log_text,0,0,current_user(),now());

return retGUID;

END'
no viable alternative at input 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1\n    DETERMINISTIC\nBEGIN\n\nDECLARE retGUID char(32);\n\nset retGUID = replace(uuid(),'-','');\n\n\ninsert into sql_log values(retGUID,log_type,log_text,0,0,current_user('
	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241)
	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:607)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1104)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:955)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:595)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:839)
	at java.lang.Thread.run(Thread.java:748)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1
    DETERMINISTIC
BEGIN

DECLARE retGUID char(32);

set retGUID = replace(uuid(),'-','');


insert into sql_log values(retGUID,log_type,log_text,0,0,current_user(),now());

return retGUID;

END'
no viable alternative at input 'CREATE DEFINER=`root`@`localhost` FUNCTION `sql_log_start`(log_type varchar(50),log_text varchar(255)) RETURNS char(32) CHARSET latin1\n    DETERMINISTIC\nBEGIN\n\nDECLARE retGUID char(32);\n\nset retGUID = replace(uuid(),'-','');\n\n\ninsert into sql_log values(retGUID,log_type,log_text,0,0,current_user('
	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:1157)
	at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:885)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72)
	at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45)
	at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:80)
	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:326)
	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:810)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:590)
	... 5 more
Caused by: org.antlr.v4.runtime.NoViableAltException
	at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026)
	at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
	at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
	at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:959)
	... 12 more