美文网首页kafka专题
Kafka专题:3.kafka协调者

Kafka专题:3.kafka协调者

作者: 北交吴志炜 | 来源:发表于2019-02-07 19:23 被阅读0次

    主消费者负责计算分区的分配,将结果发送给协调者。所有消费者从协调者处获取自己的分区信息。
    每个消费者需要发送两种请求给协调者
    1.加入组请求。协调者收集消费组的所有消费者,并选举出一个主消费者执行分区分配工作。
    2.同步组请求。主消费者完成分区分配,由协调者将分区的分配结果传播给每个消费者。

    消费组的状态主要有下面3个
    1.准备再平衡:有消费者离开或者加入消费组,需要执行一次rebalance
    2.等待同步:协调者等待主消费者的分区分配结果
    3.稳定:协调者返回分区分配结果给消费者

    协调者除了管理消费者的负载均衡,将分区的分配发送给消费者。还会接收消费者的心跳,以此监控,消费者成员是否还存活。

    相关文章

      网友评论

        本文标题:Kafka专题:3.kafka协调者

        本文链接:https://www.haomeiwen.com/subject/xfhgsqtx.html