|
@@ -317,6 +317,9 @@ public class MysqlConnector {
|
|
|
// fixed issue https://github.com/alibaba/canal/pull/4767, support mysql 8.0.30+
|
|
|
header = cachingSha2PasswordFullAuth(channel, header, getPassword().getBytes(), scramble);
|
|
|
body = PacketManager.readBytes(channel, header.getPacketBodyLength(), timeout);
|
|
|
+ } else {
|
|
|
+ header = PacketManager.readHeader(channel, 4);
|
|
|
+ body = PacketManager.readBytes(channel, header.getPacketBodyLength(), timeout);
|
|
|
}
|
|
|
}
|
|
|
} else {
|