问题描述
我正在运行Kafka Mirrormaker 2以复制数据。在3节点群集中，当我在task.max等于3的单节点中启动流程时，将创建3个任务，并以循环方式将主题分区分配给这些任务。
当我在其他2个节点上启动镜像制作器过程时，最终整个集群中只有3个任务处于活动状态。也就是说，每个节点都有一个复制一组主题分区的任务。
当task.max等于5时，在整个集群中，将运行5个MirrorSourceTasks。
那么在什么基础上创建新工作人员时，任务将被重新分配？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）