clusterBalanceJobTask报错，导致集群均衡任务状态无法更新

[zhaoli2333]

• 我已经在 issues 搜索过相关问题了,并没有重复的。

环境信息

• KnowStreaming version : ve_3.x
• Operating System version : centos7
• Java version : 11

重现该问题的步骤

1. kafka集群版本2.8.2

2. 执行集群均衡任务，一段时间后实际上副本已迁移完，但任务状态一直是doing，子任务状态一直未完成。

3. 查看服务端日志发现clusterBalanceJobTask有报错：

ElectionNotNeededException: Leader election not needed for topic partition

原因是重选leader失败，导致更新任务状态的update语句一直被回滚。