[2017-04-07 20:34:20,017] INFO Stopping MySQL connector task (io.debezium.connector.mysql.MySqlConnectorTask:218)
[2017-04-07 20:34:20,022] ERROR Failed to start the connector (see other exception), but got this error while cleaning up (io.debezium.connector.mysql.MySqlConnectorTask:183)
java.lang.NullPointerException
        at io.debezium.connector.mysql.MySqlConnectorTask.stop(MySqlConnectorTask.java:220)
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:180)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:141)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:139)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:182)
        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:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
[2017-04-07 20:34:20,028] ERROR Task pushdb-connector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:141)
org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'DELETE':  ===>> DELETE FROM CFG_PROP
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:141)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:139)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:182)
        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:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'DELETE':  ===>> DELETE FROM CFG_PROP
        at io.debezium.text.TokenStream.consume(TokenStream.java:737)
        at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568)
        at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376)
        at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:156)
        at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286)
        at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267)
        at io.debezium.relational.history.AbstractDatabaseHistory.lambda$recover$0(AbstractDatabaseHistory.java:57)
        at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:202)
        at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:52)
        at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:312)
        at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:116)
        at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:80)
        ... 8 more
[2017-04-07 20:34:20,032] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:142)
[2017-04-07 20:34:20,033] INFO Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:689)

{
  "source" : {
    "server" : "pushdb"
  },
  "position" : {
    "ts_sec" : 1491558313,
    "file" : "mysql-bin-changelog.119727",
    "pos" : 813,
    "server_id" : 1632581618,
    "event" : 1
  },
  "databaseName" : "jreportSystem",
  "ddl" : "DELETE FROM CFG_PROPS_2 WHERE PROP_NAME='GlobalDB_Status'"
}