Kafka核心技术与实战

本文基于<Kafka 核心技术与实战>,介绍了

• kafka用zk维护集群信息,broker,topic等.

• producer生产消息,通过tcp通信,同步或者异步发送给broker.

• 将一个topic分为多个partation分散到不同的broker.

• leader副本在收到消息后,先存到内存,按照顺序flush到磁盘.leader副本对外提供服务.

• follow副本进行数据拉取ack确认.

• 消费者在启动后,通过tcp通信,获取协调者.

• 通过协调者获取其partation所在的broker.

• 消费者同步或者异步消费消息.