简介:
Kafka 是⼀种高
吞吐量、分布式、基于发布/订阅的消息系统
,最初由
LinkedIn
公司开发,使⽤
Scala语⾔编写
,⽬前是 Apache 的开源项⽬。
broker:Kafka 服务器,负责消息存储和转发topic:消息类别, Kafka 按照 topic 来分类消息
partition:topic 的分区,⼀个 topic 可以包含多个 partition,topic 消息保存在各个partition 上
offffset:消息在⽇志中的位置,可以理解是消息在 partition 上的偏移量,也是代表该消息的唯⼀序号
Producer:消息⽣产者Consumer:消息消费者
Consumer Group:消费者分组,每个 Consumer 必须属于⼀个
groupZookeeper:保存着集群 broker、 topic、 partition 等meta 数据;
另外,还负责broker 故障发现, partition leader 选举,负载均衡等功能