我想知道我理解的结构是否正确 .

Kafka 方面是 生产环境 者,消费者和动物园管理员团体 . 它就主题进行通信,并且分区是并行处理单元,只有重放领导才能输入和输出 .

当制片人随机询问Kafka“分区有哪些,谁是领导者”时 . Kafka 向动物园管理员询问,然后回应 . 得到答案的制作人向Kafka Broker发送消息 . 然后经纪人接收它,保存它,并通知任何动物园管理员 . (增加抵消)在这里,动物园管理员将收到的信息发送给动物园管理员领导,动物园管理员领导通知另一个动物园管理员 . 如果领导者死亡,领导者将被替换为“Zookeeper Arctic broadcast”方式 .

此外,如果Kafka分区负责人死亡,Kafka Controller会识别它并管理分区负责人 . 整个过程完成后,它会向消费者发送消息 .

它是否正确?

我有个问题 . 如果只有一个 生产环境 者太忙,只有接收该信息的分区变得非常繁忙?是否必须手动管理?