diff --git a/docs/io-cdc-debezium.md b/docs/io-cdc-debezium.md
index a9f59b3b5bbe..537fc281aa05 100644
--- a/docs/io-cdc-debezium.md
+++ b/docs/io-cdc-debezium.md
@@ -170,6 +170,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/docs/io-debezium-source.md b/docs/io-debezium-source.md
index e824f93da134..7644eed64b67 100644
--- a/docs/io-debezium-source.md
+++ b/docs/io-debezium-source.md
@@ -220,6 +220,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```bash
diff --git a/versioned_docs/version-2.10.x/io-cdc-debezium.md b/versioned_docs/version-2.10.x/io-cdc-debezium.md
index ef825fdc9a85..cb2c8e0083ee 100644
--- a/versioned_docs/version-2.10.x/io-cdc-debezium.md
+++ b/versioned_docs/version-2.10.x/io-cdc-debezium.md
@@ -182,6 +182,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.10.x/io-debezium-source.md b/versioned_docs/version-2.10.x/io-debezium-source.md
index 5299e81e1ee8..7065822781d2 100644
--- a/versioned_docs/version-2.10.x/io-debezium-source.md
+++ b/versioned_docs/version-2.10.x/io-debezium-source.md
@@ -241,6 +241,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.11.x/io-cdc-debezium.md b/versioned_docs/version-2.11.x/io-cdc-debezium.md
index aa1752813166..6670d4ef3e57 100644
--- a/versioned_docs/version-2.11.x/io-cdc-debezium.md
+++ b/versioned_docs/version-2.11.x/io-cdc-debezium.md
@@ -170,6 +170,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.11.x/io-debezium-source.md b/versioned_docs/version-2.11.x/io-debezium-source.md
index 2a5d34d451c0..6b4287e039b8 100644
--- a/versioned_docs/version-2.11.x/io-debezium-source.md
+++ b/versioned_docs/version-2.11.x/io-debezium-source.md
@@ -220,6 +220,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```bash
diff --git a/versioned_docs/version-2.5.0/io-cdc-debezium.md b/versioned_docs/version-2.5.0/io-cdc-debezium.md
index f2db39520919..541bfdd0c11c 100644
--- a/versioned_docs/version-2.5.0/io-cdc-debezium.md
+++ b/versioned_docs/version-2.5.0/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.5.0/io-debezium-source.md b/versioned_docs/version-2.5.0/io-debezium-source.md
index 7cc543c84c8d..0bdefb132dc5 100644
--- a/versioned_docs/version-2.5.0/io-debezium-source.md
+++ b/versioned_docs/version-2.5.0/io-debezium-source.md
@@ -172,6 +172,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
@@ -305,7 +334,7 @@ This example shows how to change the data of a PostgreSQL table using the Pulsar
 
    ```
 
-6. A MySQL client pops out.
+6. A PostgreSQL client pops out.
 
    Use the following commands to change the data of the table _products_.
 
diff --git a/versioned_docs/version-2.5.1/io-cdc-debezium.md b/versioned_docs/version-2.5.1/io-cdc-debezium.md
index f2db39520919..541bfdd0c11c 100644
--- a/versioned_docs/version-2.5.1/io-cdc-debezium.md
+++ b/versioned_docs/version-2.5.1/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.5.1/io-debezium-source.md b/versioned_docs/version-2.5.1/io-debezium-source.md
index 7193648b0535..b6e43d7e7bd1 100644
--- a/versioned_docs/version-2.5.1/io-debezium-source.md
+++ b/versioned_docs/version-2.5.1/io-debezium-source.md
@@ -183,6 +183,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.5.2/io-cdc-debezium.md b/versioned_docs/version-2.5.2/io-cdc-debezium.md
index f2db39520919..541bfdd0c11c 100644
--- a/versioned_docs/version-2.5.2/io-cdc-debezium.md
+++ b/versioned_docs/version-2.5.2/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.5.2/io-debezium-source.md b/versioned_docs/version-2.5.2/io-debezium-source.md
index 7193648b0535..b6e43d7e7bd1 100644
--- a/versioned_docs/version-2.5.2/io-debezium-source.md
+++ b/versioned_docs/version-2.5.2/io-debezium-source.md
@@ -183,6 +183,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.0/io-cdc-debezium.md b/versioned_docs/version-2.6.0/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.6.0/io-cdc-debezium.md
+++ b/versioned_docs/version-2.6.0/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.0/io-debezium-source.md b/versioned_docs/version-2.6.0/io-debezium-source.md
index 6e133b6b518d..05a704e2e383 100644
--- a/versioned_docs/version-2.6.0/io-debezium-source.md
+++ b/versioned_docs/version-2.6.0/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.1/io-cdc-debezium.md b/versioned_docs/version-2.6.1/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.6.1/io-cdc-debezium.md
+++ b/versioned_docs/version-2.6.1/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.1/io-debezium-source.md b/versioned_docs/version-2.6.1/io-debezium-source.md
index 6e133b6b518d..05a704e2e383 100644
--- a/versioned_docs/version-2.6.1/io-debezium-source.md
+++ b/versioned_docs/version-2.6.1/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.2/io-cdc-debezium.md b/versioned_docs/version-2.6.2/io-cdc-debezium.md
index ef1d0023f981..52872f97252b 100644
--- a/versioned_docs/version-2.6.2/io-cdc-debezium.md
+++ b/versioned_docs/version-2.6.2/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.2/io-debezium-source.md b/versioned_docs/version-2.6.2/io-debezium-source.md
index 6e133b6b518d..05a704e2e383 100644
--- a/versioned_docs/version-2.6.2/io-debezium-source.md
+++ b/versioned_docs/version-2.6.2/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.3/io-cdc-debezium.md b/versioned_docs/version-2.6.3/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.6.3/io-cdc-debezium.md
+++ b/versioned_docs/version-2.6.3/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.3/io-debezium-source.md b/versioned_docs/version-2.6.3/io-debezium-source.md
index 6e133b6b518d..05a704e2e383 100644
--- a/versioned_docs/version-2.6.3/io-debezium-source.md
+++ b/versioned_docs/version-2.6.3/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.4/io-cdc-debezium.md b/versioned_docs/version-2.6.4/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.6.4/io-cdc-debezium.md
+++ b/versioned_docs/version-2.6.4/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.6.4/io-debezium-source.md b/versioned_docs/version-2.6.4/io-debezium-source.md
index 6e133b6b518d..05a704e2e383 100644
--- a/versioned_docs/version-2.6.4/io-debezium-source.md
+++ b/versioned_docs/version-2.6.4/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.0/io-cdc-debezium.md b/versioned_docs/version-2.7.0/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.0/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.0/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.0/io-debezium-source.md b/versioned_docs/version-2.7.0/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.0/io-debezium-source.md
+++ b/versioned_docs/version-2.7.0/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.1/io-cdc-debezium.md b/versioned_docs/version-2.7.1/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.1/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.1/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.1/io-debezium-source.md b/versioned_docs/version-2.7.1/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.1/io-debezium-source.md
+++ b/versioned_docs/version-2.7.1/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.2/io-cdc-debezium.md b/versioned_docs/version-2.7.2/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.2/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.2/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.2/io-debezium-source.md b/versioned_docs/version-2.7.2/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.2/io-debezium-source.md
+++ b/versioned_docs/version-2.7.2/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.3/io-cdc-debezium.md b/versioned_docs/version-2.7.3/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.3/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.3/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.3/io-debezium-source.md b/versioned_docs/version-2.7.3/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.3/io-debezium-source.md
+++ b/versioned_docs/version-2.7.3/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.4/io-cdc-debezium.md b/versioned_docs/version-2.7.4/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.4/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.4/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.4/io-debezium-source.md b/versioned_docs/version-2.7.4/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.4/io-debezium-source.md
+++ b/versioned_docs/version-2.7.4/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.5/io-cdc-debezium.md b/versioned_docs/version-2.7.5/io-cdc-debezium.md
index c5e03763a404..95ea6b52a0ad 100644
--- a/versioned_docs/version-2.7.5/io-cdc-debezium.md
+++ b/versioned_docs/version-2.7.5/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.7.5/io-debezium-source.md b/versioned_docs/version-2.7.5/io-debezium-source.md
index 6ede7980e630..1390bf7afbb8 100644
--- a/versioned_docs/version-2.7.5/io-debezium-source.md
+++ b/versioned_docs/version-2.7.5/io-debezium-source.md
@@ -201,6 +201,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.8.x/io-cdc-debezium.md b/versioned_docs/version-2.8.x/io-cdc-debezium.md
index cd7b9f6c10f8..c3a8c0b1da10 100644
--- a/versioned_docs/version-2.8.x/io-cdc-debezium.md
+++ b/versioned_docs/version-2.8.x/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.8.x/io-debezium-source.md b/versioned_docs/version-2.8.x/io-debezium-source.md
index c76106a24508..3ffde420a543 100644
--- a/versioned_docs/version-2.8.x/io-debezium-source.md
+++ b/versioned_docs/version-2.8.x/io-debezium-source.md
@@ -214,6 +214,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.9.x/io-cdc-debezium.md b/versioned_docs/version-2.9.x/io-cdc-debezium.md
index cd7b9f6c10f8..c3a8c0b1da10 100644
--- a/versioned_docs/version-2.9.x/io-cdc-debezium.md
+++ b/versioned_docs/version-2.9.x/io-cdc-debezium.md
@@ -180,6 +180,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-2.9.x/io-debezium-source.md b/versioned_docs/version-2.9.x/io-debezium-source.md
index 1b0614c9ea60..502c574e0a99 100644
--- a/versioned_docs/version-2.9.x/io-debezium-source.md
+++ b/versioned_docs/version-2.9.x/io-debezium-source.md
@@ -239,6 +239,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-3.0.x/io-cdc-debezium.md b/versioned_docs/version-3.0.x/io-cdc-debezium.md
index a9f59b3b5bbe..537fc281aa05 100644
--- a/versioned_docs/version-3.0.x/io-cdc-debezium.md
+++ b/versioned_docs/version-3.0.x/io-cdc-debezium.md
@@ -170,6 +170,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```
diff --git a/versioned_docs/version-3.0.x/io-debezium-source.md b/versioned_docs/version-3.0.x/io-debezium-source.md
index e824f93da134..7644eed64b67 100644
--- a/versioned_docs/version-3.0.x/io-debezium-source.md
+++ b/versioned_docs/version-3.0.x/io-debezium-source.md
@@ -220,6 +220,35 @@ This example shows how to change the data of a MySQL table using the Pulsar Debe
 
 6. A MySQL client pops out.
 
+   Change the connection mode to `mysql_native_password`.
+   ```
+   mysql> show variables like "caching_sha2_password_auto_generate_rsa_keys";
+   +----------------------------------------------+-------+
+   | Variable_name                                | Value |
+   +----------------------------------------------+-------+
+   | caching_sha2_password_auto_generate_rsa_keys | ON    |
+   +----------------------------------------------+-------+
+
+   # If the value of "caching_sha2_password_auto_generate_rsa_keys" is ON, ensure the plugin of mysql.user is "mysql_native_password".
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | caching_sha2_password |
+   +-----------+------+-----------------------+
+
+   # If the plugin of mysql.user is is "caching_sha2_password", set it to "mysql_native_password".
+   alter user '{user}'@'{host}' identified with mysql_native_password by {password};
+
+   # Check the plugin of mysql.user.
+   mysql> SELECT Host, User, plugin from mysql.user where user={user};
+   +-----------+------+-----------------------+
+   | Host      | User | plugin                |
+   +-----------+------+-----------------------+
+   | localhost | root | mysql_native_password |
+   +-----------+------+-----------------------+
+   ```
+
    Use the following commands to change the data of the table _products_.
 
    ```bash