kafka集群数据迁移双向认证方法及装置

本申请实施例提供一种kafka集群数据迁移双向认证方法及装置，方法包括：通过第一kafka集群向第二kafka集群发送认证请求，第二kafka集群根据预设认证机制对第一kafka集群进行正向身份认证，若正向认证成功，则第二kafka集群根据预设密码认证信息向第一kafka集群发送认证请求进行反向身份认证，若反向身份认证失败，则根据重连机制模型进行重新连接，若反向身份认证成功，则完成kafka集群间的数据迁移，其中，重连机制模型是根据认证失败特征、网络延迟特征、重新连接特征、系统负载特征以及负载优化特征构建的状态空间和重新连接间隔时间、重新连接次数构建的动作空间进行模型训练后得到的，本申请能够提高Kafka集群数据迁移的效率和安全性。