包括三个角色:
producer: 可以是flume,java程序,socket,service
通过push向broker中生产数据
broker: 缓冲数据
集群的吞吐量,broker的个数
向zk中进行注册
zk: broker和其他的元信息,协调broker和broker的通信,broker的位置的协同
consumer:
通过pull从broker中消费数据
多个comsumer可以组成一个Group
向zk中进行注册
消费者是通过zk知晓其关注主题的数据的状态
数据从productor发送到broker中间缓存和分发数据,注册到系统中的consumer