1、消息存储以及生产消费模型
一个topic分成多个partition,每个partition内部有序,其中每个消息有个序号叫offset,一个partition只对应一个broker,一个broker可以管理多个partition。消息不需要经过内存缓冲,直接写入到文件中根据实际策略删除,而不是消费完就删除,Producer自己决定往哪个partition中写消息。
Kafka中的消息都是topic来组织的,相当于一个队列,分为多个partition(做并行),每个partition内部有序,每一个消息一个序号。
2、特点:
生产者消费者模型:FIFO先进先出
高性能:单节点支持上千个客户端,百M/s的吞吐
持久性:消息直接持久化到普通磁盘(顺序写要比固态硬盘随机写快很多)
分布式:副本冗余、流量负载均衡
>