摘自:https://www.bilibili.com/video/BV1vx411f7hA?from=search&seid=7953675259135315312
发布与订阅系统,微信公众号模式
kafka就是接受不同生产者的消息,然后由不同的消费者订阅这些消息供自己使用
三个名词:消息,生产者,消费者
消息:就是数据库的一行信息
生产者:发布消息的程序
消费者:订阅消息的程序
消息包括:主题、分区、键、值
键:标记
分区器:一个排序算法
生产者把消息放到指定分区,不指定分区就根据分区器通过键来指定
读数据根据偏移量(第几个)来读取,必须顺序读取
暂且认为是集群中的每一个服务器就是一个broker,broker理解成kafka的实例,每一个broker可以有多个topic(消息的分类),每一个topic也可以分多个分区partition(比如:货架),消息就存在这些分区上,根据偏移量来获取数据。
kafka支持多副本模式(理解成备份),一个broker挂掉之后可以从另一个broker中获取数据。
网友评论