{
  "source" : {
    "server" : "localhost.9092"
  },
  "position" : {
    "file" : "mysql-bin.000001",
    "pos" : 151,
    "snapshot" : true
  },
  "databaseName" : "auth_context_local",
  "ddl" : "CREATE TABLE `roles` (\n  `id` varchar(32) NOT NULL,\n  `name` varchar(100) NOT NULL,\n  `context` varchar(20) NOT NULL,\n  `organization_id` int(11) DEFAULT NULL,\n  `client_id` varchar(32) NOT NULL,\n  `scope_action_ids` text NOT NULL,\n  PRIMARY KEY (`id`),\n  FULLTEXT KEY `scope_action_ids_idx` (`scope_action_ids`)\n) ENGINE=InnoDB DEFAULT CHARSET=utf8"
}

[2017-02-10 19:37:04,731] ERROR Task cep_debezium_mysql-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142)
org.apache.kafka.connect.errors.ConnectException: io.debezium.text.ParsingException: Expecting ')' at line 9, column 16 but found 'scope_action_ids_idx': `),
  FULLTEXT KEY ` ===>> scope_action_ids_idx
	at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:192)
	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:137)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
	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 ')' at line 9, column 16 but found 'scope_action_ids_idx': `),
  FULLTEXT KEY ` ===>> scope_action_ids_idx
	at io.debezium.text.TokenStream.consume(TokenStream.java:694)
	at io.debezium.connector.mysql.MySqlDdlParser.parseCreateDefinitionList(MySqlDdlParser.java:546)
	at io.debezium.connector.mysql.MySqlDdlParser.parseCreateTable(MySqlDdlParser.java:363)
	at io.debezium.connector.mysql.MySqlDdlParser.parseCreate(MySqlDdlParser.java:266)
	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:141)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
	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-02-10 19:37:04,731] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:143)