Kafka连接任务分配流

3b6akqbq  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(261)

我正在运行kafka mirrormaker 2来复制数据。在3节点集群中,当我在tasks.max等于3的单节点中启动进程时,将创建3个任务,并以循环方式将topicpartitions分配给这些任务。
当我在其他2个节点中启动mirror maker进程时,最后整个集群中只有3个任务处于活动状态。也就是说,每个节点有一个复制一组主题分区的任务。
当tasks.max等于5时,集群中有5个mirrorsourcetasks正在运行。
那么在什么基础上,当一个新的工人被创建时,任务将被重新分配?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题