基础概念学习 一.基础概念二.结构图 一.基础概念 Kafka 基本概念:一种分布式的,基于发布/订阅的消息系统 项目ValueBrokerKafka服务端(即部署了Kafka的机器)Producer生产者写数据到主副本Consumer消费者从主副本读数据Consumer Group消费者组,同一个组下可以订阅多个Topic,每个Topic分区不允许重复消费;多个不同组可以消费同一个Topic的同一个分区BrokerKafka服务端一个实例(一台机器),每台实例上分布有主副本或从副本Topic主题,所有数据基于主题和分区实现隔离与交互(多个消息队列组合)Partition分区,对应于某个主题的一个数据分区(消息队列),提高并发读写能力Offset偏移,某个消费在某个Topic的某个Partition下的偏移位置Leader主副本,与生产者和消费者交互,完成数据读写Follower从副本,从主副本同步数据,保证系统的高可用ZooKeeper/KRaft注册中心,用于管理主题、分区、偏移量、生产者、消费者的绑定关系Reblance重平衡,消费者心跳线程与Coordinator通信,消费者宕机等异常导致的心跳超时将触发重平衡ISR(IN-SYNC REPLICAS)从副本同步进度,被认为不同步的Broker将被剔除出列表,无法参与主节点的选举 二.结构图