6.3Kafka的核心组件介绍
核心组件:
组件名称 |
相关说明 |
Topic |
特定类别消息流称为主题,数据存在主题中,主题被拆分成分区 |
Partition |
主题的数据分割为一个或多个分区,每个分区的数据使用多个segment文件存储,分区中的数据是有序的 |
Offset |
每个分区消息具有的唯一序列标识 |
Replica |
副本只是一个分区的备份,它们用于防止数据丢失 |
Producer |
生产者即数据发布者,该角色将消息发布到Kafka集群主题中 |
Consumer |
消费者可从Broker中读取数据,可消费多个主题数据 |
Broker |
每个Kafka服务节点都为Broker,Broker接收消息后,将消息追加到segment文件中 |
Leader |
负责分区的所有读写操作 |
Follower |
跟随领导指令,若Leader发生故障则选一个Follower为新Leader |
Consumer Group |
实现一个主题消息的广播和单播的手段 |
Last modified: Friday, 29 October 2021, 12:32 PM