"CREATE TABLE IF NOT EXISTS tables_exception 
(
table_name VARCHAR(100),
create_date TIMESTAMP DEFAULT NOW(),
enabled INT(1),
retention int(1) default 30,
CONSTRAINT PRIMARY KEY (table_name))
"

"{"name":"KS5014-new","connector":{"state":"RUNNING","worker_id":"10.53.220.219:8083"},"tasks":[{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Expecting ')' at line 7, column 24 but found '(': STRAINT PRIMARY KEY  ===>> (table_name)\n)\n\tat io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)\n\tat io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142)\n\tat io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:332)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)\n\tat java.lang.Thread.run(Unknown Source)\nCaused by: io.debezium.text.ParsingException: Expecting ')' at line 7, column 24 but found '(': STRAINT PRIMARY KEY  ===>> (table_name)\n)\n\tat io.debezium.text.TokenStream.consume(TokenStream.java:706)\n\tat io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:563)\n\tat io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:378)\n\tat io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:281)\n\tat io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:152)\n\tat io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286)\n\tat io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)\n\tat io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:354)\n\tat io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:466)\n\tat io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319)\n\t... 5 more\n","id":0,"worker_id":"10.53.220.219:8083"}]}
"