-
Bug
-
Resolution: Done
-
Minor
-
0.5
-
None
-
CentOS 7
Whenever we are restarting the server, the connector will show it is connected but it is not consuming the data. It is working fine when we are restarting the connector.
The logs looks like
Unable to find source-code formatter for language: txt. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml
INFO MySQL|whole-msr|binlog Stopped reading binlog after 17720065 events, last recorded offset: {ts_sec=1490988983, file=mysql-bin.000344, pos=5747093, row=29, server_id=204658455, event=4} [io.debezium.connector.mysql.BinlogReader]
2017-04-12 16:35:56,228 ERROR || Task attendance-connector-0 threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:131)
at io.debezium.connector.mysql.BinlogReader$ReaderThreadLifecycleListener.onCommunicationFailure(BinlogReader.java:702)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:768)
at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.EOFException
at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:190)
at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.readInteger(ByteArrayInputStream.java:46)
at com.github.shyiko.mysql.binlog.event.deserialization.EventHeaderV4Deserializer.deserialize(EventHeaderV4Deserializer.java:35)
at com.github.shyiko.mysql.binlog.event.deserialization.EventHeaderV4Deserializer.deserialize(EventHeaderV4Deserializer.java:27)
at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:175)
at io.debezium.connector.mysql.BinlogReader$1.nextEvent(BinlogReader.java:116)
at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:741)
... 3 more
2017-04-12 16:35:56,230 ERROR || Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]
Apr 12, 2017 4:36:02 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
INFO: Trying to restore lost connection to localhost:3306
Apr 12, 2017 4:36:02 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
WARNING: Failed to restore connection to localhost:3306. Next attempt in 60000ms
Apr 12, 2017 4:36:14 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
INFO: Trying to restore lost connection to localhost:3306
Apr 12, 2017 4:36:14 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
WARNING: Failed to restore connection to localhost:3306. Next attempt in 60000ms
Apr 12, 2017 4:37:02 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
INFO: Trying to restore lost connection to localhost:3306
Apr 12, 2017 4:37:02 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
INFO: Connected to localhost:3306 at mysql-bin.000366/33618385 (sid:5020, cid:67)
2017-04-12 16:37:02,064 INFO MySQL|attendance|binlog Connected to MySQL binlog at localhost:3306, starting at binlog file 'mysql-bin.000366', pos=33618071, skipping 4 events plus 0 rows [io.debezium.connector.mysql.BinlogReader]
Apr 12, 2017 4:37:14 PM com.github.shyiko.mysql.binlog.BinaryLogClient$3 run
INFO: Trying to restore lost connection to localhost:3306
Apr 12, 2017 4:37:14 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
INFO: Connected to localhost:3306 at mysql-bin.000366/33618385 (sid:5810, cid:86)
2017-04-12 16:37:14,597 INFO MySQL|whole-msr|binlog Connected to MySQL binlog at localhost:3306, starting at binlog file 'mysql-bin.000366', pos=4, skipping 11158039 events plus 0 rows [io.debezium.connector.mysql.BinlogReader]
- is related to
-
DBZ-248 Re-connect not working for MySQL during streaming
-
- Closed
-