Соединитель MySQL Debezium - io.debezium.text.ParsingException - PullRequest
Новая
       7

Соединитель MySQL Debezium - io.debezium.text.ParsingException

1 голос
/ 29 июня 2019

Дебезиум перестал работать сразу после того, как я добавил TRIGGERS в свои таблицы MySQL.

Это то, что я получил в журналах соединителей 

Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: org.apache.kafka.connect.errors.ConnectException: no viable alternative at input 'CREATE DEFINER=`root`@`%` TRIGGER `gxapp_customer_db.BCAVAActivationApprovedReports_AI`                                                                 AFTER INSERT                                                                ON `BCAVAActivationApprovedReports`                                                              FOR EACH ROW                                                                 BEGIN                                                                DECLARE has_error BOOLEAN DEFAULT 0;                                                             DECLARE duplicate_key CONDITION FOR 1062;                                              DECLARE foreign_key_violated CONDITION FOR 1216;
DECLARE revision_inc INT'
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: at java.lang.Thread.run(Thread.java:748)
Jun 29 16:29:24 log.gxapp-crm.com sh[4827]: Caused by: io.debezium.text.ParsingException: no viable alternative at input 'CREATE DEFINER=`root`@`%` TRIGGER `gxapp_customer_db.BCAVAActivationApprovedReports_AI`                                                  AFTER INSERT                                                                ON `BCAVAActivationApprovedReports`                                                               FOR EACH ROW
BEGIN
DECLARE has_error BOOLEAN DEFAULT 0;                                                              DECLARE duplicate_key CONDITION FOR 1062;                                                                 DECLARE foreign_key_violated CONDITION FOR 1216;                                                                 DECLARE revision_inc INT'

Я попытался удалить соединители и добавил его обратно.

Имеет ли это какое-либо отношение к функции триггера?Разве это еще не поддерживается Debezium?

...