kafka 是一个 分布式的发布订阅形式的消息系统。
作为一个消息系统,kafka 有着 削峰,解耦,异步 的作用。
自身特点:
1)只有发布订阅模式 ,其他消息中间件 还有 点对点模式。
2)消息被消费后,还能存留,保留时间可自定义。
kafka 整个系统包含 server 和 client,它们之间通过 tcp 协议通讯。
server:服务端,以集群 的方式运行。集群可以包含一个或多个服务器 。存储数据的服务器称为 broker。
client:客户端,生产者 和 消费者 都是客户端。
消息 -> topic -> replica -> partition
消息 存在 topic 中,每个 topic 都可以有主从备份(leader,follower),消息分散在各个分片中。
主从备份可以提高可用性,即使单个broker不可用,也不会导致整个系统不可用。
分片存储可以水平扩展存储容量,提高服务器负载能力。存更多,读写更快。
原文:https://www.cnblogs.com/zhanglw456/p/14723022.html