出现重新平衡问题的原因是因为在 Kafka Connect 集群中某个工作器挂掉或重启后，重新平衡会发生，这将导致一些 Connector 的重新分配和停止。为了解决此问题，可以添加以下详细步骤：

1. 在 Connect REST API 中，先暂停所有的 Connector，并将工作器配置文件中的以下属性设置为False以关闭自动提交偏移量：

"config" : { ..... "offset.storage.auto.commit.enabled": false, ..... }

2. 关闭所有的 Connect 工作器。等到所有工作器都已关闭之后，在 Connect REST API 中重新启动工作器。

3. 在启动工作器之前，请先确保所有的 Connector 都已停止，以避免重新分配的情况出现。

4. 启动工作器并恢复先前暂停的所有 Connector。

以下是具体示例：

curl -X PUT -H "Content-Type:application/json"
http://localhost:8083/connectors/source-mysql/pause

设置自动提交偏移量属性为False

curl -X PUT -H "Content-Type:application/json"
http://localhost:8083/admin/workers/worker1/config
-d '{"config": {"offset.storage.auto.commit.enabled": false}}'

curl -X PUT -H "Content-Type:application/json"
http://localhost:8083/admin/workers/worker2/config
-d '{"config": {"offset.storage.auto.commit.enabled": false}}'

curl -X POST -H "Content-Type:application/json"
http://localhost:8083/admin/workers/worker1/restart

确认所有Connector都已停止

curl -X GET -H "Content-Type:application/json"
http://localhost:8083/connectors

curl -X POST -H "Content-Type:application/json"
http://localhost:8083/admin/workers/worker2/restart