From 2b531642534c1368a0bade8201eb5e888b4f25ac Mon Sep 17 00:00:00 2001
From: kkz-01 <2281574465@qq.com>
Date: Fri, 16 May 2025 15:06:36 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B38.0.30+=E4=BD=BF=E7=94=A8cahc?=
 =?UTF-8?q?ing=5Fsha2=5Fpassword=E6=97=B6Fastauth=E6=8A=A5=E9=94=99?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=20(#5406)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: zhangkai <zhangkai02@xgd.com>
---
 .../alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java
index 91bc273f..e4646056 100644
--- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java
+++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java
@@ -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 {