生产消费者模式,生产者向Topic 发布消息,消费者 从Topic 订阅消息。

    一个topic实际是由多个partition组成的,通过增加partition的数量来进行横向扩容。单个parition内是保证消息有序。

    image.png

    Producers,往 Brokers里面的指定Topic中写消息;Consumers,从Brokers里面拉取指定Topic的消息,进行业务处理。

    有两个topic,topic 0有两个partition,topic 1有一个partition,三副本备份。

    consumer gourp 1中的consumer 2没有分到partition处理

    1. brokertopicspartitions的一些元信息用zk来存,监控和路由啥的也都会用到zk