Message dropped on Oracle topic cannot auto create table in MYSQL using jdbc sink

[kriskrishna]

[2022-02-03 17:14:45,496] INFO JdbcDbWriter Connected (io.confluent.connect.jdbc.sink.JdbcDbWriter) connect | [2022-02-03 17:14:45,822] INFO Checking MySql dialect for existence of TABLE "ORCLCDB"."C__MYUSER"."EMP" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect) connect | [2022-02-03 17:14:45,862] INFO Using MySql dialect TABLE "ORCLCDB"."C__MYUSER"."EMP" absent (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect) connect | [2022-02-03 17:14:45,862] INFO Creating table with sql: CREATE TABLE ORCLCDB.C__MYUSER.EMP ( connect | I DECIMAL(65,0) NOT NULL, connect | NAME TEXT NULL, connect | table TEXT NULL, connect | scn TEXT NULL, connect | op_type TEXT NULL, connect | op_ts TEXT NULL, connect | current_ts TEXT NULL, connect | row_id TEXT NULL, connect | username TEXT NULL, connect | name TEXT NOT NULL, connect | PRIMARY KEY(name)) (io.confluent.connect.jdbc.sink.DbStructure) connect | [2022-02-03 17:14:45,885] WARN Create failed, will attempt amend if table already exists (io.confluent.connect.jdbc.sink.DbStructure) connect | java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '.EMP ( connect | I DECIMAL(65,0) NOT NULL, connect | NAME TEXT NULL, connect | table TEXT NULL, connect | scn ' at line 1 connect | at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) connect | at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)