�2017-05-13T17:05:51.150064889Z 2017-05-13 17:05:51,148 ERROR  MySQL|staging|binlog  Error parsing DDL statement and updating tables: ANALYZE TABLE `App`   [io.debezium.connector.mysql.MySqlSchema]
�2017-05-13T17:05:51.150123758Z io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'ANALYZE':  ===>> ANALYZE TABLE `App`

���2017-05-13T17:04:01.606298716Z 2017-05-13 17:04:01,605 INFO   MySQL|staging|binlog  Stopped reading binlog after 4030 events, last recorded offset: {ts_sec=1494693476, file=mysql_bin.002359, pos=18806730, row=1, server_id=10, event=2}   [io.debezium.connector.mysql.BinlogReader]
�2017-05-13T17:04:01.905567979Z 2017-05-13 17:04:01,901 ERROR  ||  Task es_pd_connector-1-0 threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
�P2017-05-13T17:04:01.905618425Z org.apache.kafka.connect.errors.ConnectException
�l2017-05-13T17:04:01.905627036Z 	at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)
�n2017-05-13T17:04:01.905633432Z 	at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:131)
�2017-05-13T17:04:01.905639932Z 	at io.debezium.connector.mysql.BinlogReader$ReaderThreadLifecycleListener.onCommunicationFailure(BinlogReader.java:676)
�2017-05-13T17:04:01.905646515Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:768)
�t2017-05-13T17:04:01.905653423Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
�r2017-05-13T17:04:01.905660149Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
�I2017-05-13T17:04:01.905666689Z 	at java.lang.Thread.run(Thread.java:745)
�?2017-05-13T17:04:01.905672322Z Caused by: java.io.EOFException
�~2017-05-13T17:04:01.905678111Z 	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:190)
�2017-05-13T17:04:01.905685060Z 	at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.readInteger(ByteArrayInputStream.java:46)
�2017-05-13T17:04:01.905690939Z 	at com.github.shyiko.mysql.binlog.event.deserialization.EventHeaderV4Deserializer.deserialize(EventHeaderV4Deserializer.java:35)
�2017-05-13T17:04:01.905697476Z 	at com.github.shyiko.mysql.binlog.event.deserialization.EventHeaderV4Deserializer.deserialize(EventHeaderV4Deserializer.java:27)
�2017-05-13T17:04:01.905703998Z 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:175)
�o2017-05-13T17:04:01.905710477Z 	at io.debezium.connector.mysql.BinlogReader$1.nextEvent(BinlogReader.java:110)
�2017-05-13T17:04:01.905716689Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:741)
�+2017-05-13T17:04:01.905723089Z 	... 3 more
�2017-05-13T17:04:01.906007197Z 2017-05-13 17:04:01,905 ERROR  ||  Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
�2017-05-13T17:04:01.906056268Z 2017-05-13 17:04:01,905 INFO   ||  Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
�l2017-05-13T17:04:55.359614214Z May 13, 2017 5:04:55 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
�^2017-05-13T17:04:55.359676684Z INFO: Trying to restore lost connection to mysql-dvaco.db:3306
�n2017-05-13T17:04:55.449259545Z May 13, 2017 5:04:55 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
�s2017-05-13T17:04:55.449307323Z INFO: Connected to mysql-dvaco.db:3306 at mysql_bin.002360/33089462 (sid:1, cid:27)
���2017-05-13T17:04:55.449595371Z 2017-05-13 17:04:55,449 INFO   MySQL|staging|binlog  Connected to MySQL binlog at mysql-dvaco.db:3306, starting at binlog file 'mysql_bin.002360', pos=33088882, skipping 4 events plus 0 rows   [io.debezium.connector.mysql.BinlogReader]
�2017-05-13T17:05:51.150064889Z 2017-05-13 17:05:51,148 ERROR  MySQL|staging|binlog  Error parsing DDL statement and updating tables: ANALYZE TABLE `App`   [io.debezium.connector.mysql.MySqlSchema]
�2017-05-13T17:05:51.150123758Z io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'ANALYZE':  ===>> ANALYZE TABLE `App`
�^2017-05-13T17:05:51.150134613Z 	at io.debezium.text.TokenStream.consume(TokenStream.java:725)
�m2017-05-13T17:05:51.150141308Z 	at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:567)
�r2017-05-13T17:05:51.150147513Z 	at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:375)
�z2017-05-13T17:05:51.150154936Z 	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:153)
�b2017-05-13T17:05:51.150165593Z 	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
�b2017-05-13T17:05:51.150176021Z 	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
�j2017-05-13T17:05:51.150186682Z 	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351)
�t2017-05-13T17:05:51.150196654Z 	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447)
�o2017-05-13T17:05:51.150207542Z 	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313)
�2017-05-13T17:05:51.150218775Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
�2017-05-13T17:05:51.150230530Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
�t2017-05-13T17:05:51.150237895Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
�r2017-05-13T17:05:51.150244457Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
�I2017-05-13T17:05:51.150250600Z 	at java.lang.Thread.run(Thread.java:745)
�2017-05-13T17:05:51.187241128Z 2017-05-13 17:05:51,186 ERROR  MySQL|staging|binlog  Error parsing DDL statement and updating tables: ANALYZE TABLE `Log`   [io.debezium.connector.mysql.MySqlSchema]
�2017-05-13T17:05:51.187267821Z io.debezium.text.ParsingException: Expecting token type 128 at line 1, column 1 but found 'ANALYZE':  ===>> ANALYZE TABLE `Log`
�^2017-05-13T17:05:51.187291614Z 	at io.debezium.text.TokenStream.consume(TokenStream.java:725)
�m2017-05-13T17:05:51.187299731Z 	at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:567)
�r2017-05-13T17:05:51.187306376Z 	at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:375)
�z2017-05-13T17:05:51.187312181Z 	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:153)
�b2017-05-13T17:05:51.187318897Z 	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
�b2017-05-13T17:05:51.187324984Z 	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
�j2017-05-13T17:05:51.187332330Z 	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351)
�t2017-05-13T17:05:51.187339215Z 	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:447)
�o2017-05-13T17:05:51.187349730Z 	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:313)
�2017-05-13T17:05:51.187359678Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
�2017-05-13T17:05:51.187370247Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
�t2017-05-13T17:05:51.187381148Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
�r2017-05-13T17:05:51.187391713Z 	at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
�I2017-05-13T17:05:51.187399808Z 	at java.lang.Thread.run(Thread.java:745)