2019-01-27 14:23:45,792 ERROR  MySQL|assetsServer|task  Unexpected exception while processing record 'ConsumerRecord(topic = assetsServer-history-topic, partition = 0, offset = 399, CreateTime = 1547558474496, serialized key size = -1, serialized value size = 300, headers = RecordH
eaders(headers = [], isReadOnly = false), key = null, value = {
  "source" : {
    "server" : "assetsServer"
  },
  "position" : {
    "ts_sec" : 1547558474,
    "file" : "mysql-bin-changelog.000002",
    "pos" : 7439884,
    "server_id" : 1384371360,
    "event" : 1
  },
  "databaseName" : "\\YOUR_USER_NAME\\",
  "ddl" : "CREATE SCHEMA `\\YOUR_USER_NAME\\`"
})'   [io.debezium.relational.history.KafkaDatabaseHistory]
io.debezium.text.ParsingException: No matching single quote found after line 1, column 15
        at io.debezium.relational.ddl.DdlTokenizer.tokenize(DdlTokenizer.java:262)
        at io.debezium.text.TokenStream.start(TokenStream.java:445)
        at io.debezium.relational.ddl.LegacyDdlParser.parse(LegacyDdlParser.java:199)
        at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:104)
        at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:238)
        at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:73)
        at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:245)
        at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:163)
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:96)
        at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:45)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:164)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
2019-01-27 14:23:45,800 INFO   MySQL|assetsServer|task  Stopping MySQL connector task   [io.debezium.connector.mysql.MySqlConnectorTask]
2019-01-27 14:23:45,801 INFO   ||  WorkerSourceTask{id=mySqlConnector25-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2019-01-27 14:23:45,801 INFO   ||  WorkerSourceTask{id=mySqlConnector25-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2019-01-27 14:23:45,801 ERROR  ||  WorkerSourceTask{id=mySqlConnector25-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: No matching single quote found after line 1, column 15
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:219)
        at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:45)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:164)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: io.debezium.text.ParsingException: No matching single quote found after line 1, column 15
        at io.debezium.relational.ddl.DdlTokenizer.tokenize(DdlTokenizer.java:262)
        at io.debezium.text.TokenStream.start(TokenStream.java:445)
        at io.debezium.relational.ddl.LegacyDdlParser.parse(LegacyDdlParser.java:199)
        at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$1(AbstractDatabaseHistory.java:104)
        at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:238)
        at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:73)
        at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:245)
        at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:163)
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:96)
        ... 9 more
2019-01-27 14:23:45,801 ERROR  ||  WorkerSourceTask{id=mySqlConnector25-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2019-01-27 14:23:45,801 INFO   ||  [Producer clientId=producer-4] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2019-01-27 14:24:33,603 INFO   ||  WorkerSourceTask{id=mySqlConnector25-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]