栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

kafka的一些概念

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

kafka的一些概念

kafka

kafka

消费组:一个消费组里包含一个或者多个消费者,一个patition只能被一个消费组里的一个consumer消费
consumer消费patition时是根据offerset来顺序消费的,
这个offerset在旧版里是保存在zookeeper,在新版是保存在kafka内部
当消费组内的consumer启动时,第一个启动的consumer会成为消费组的coordinator
消费组里的消费者会跟消费组里的coordinator发送hearthbeat,以保持consumer自己在线
当消费组内的consumer数量发生变化(譬如某个consumer宕机,增加了某个consumer),或者订阅的patition数量发生了变化,就会触发rebalance
rebalance时,消费组内的所有consumer都会向coordinator发送joinGroup
在consumer加入消费组的时候,coordinator会从中选一个consumer当leader
消费组内的leader负责消费组的消费分配策略,即哪个patition被哪个consumer消费,消费分配策略一旦分配好,就会同步到消费组内的其他consumer,这样其他consumer就知道自己是消费哪些patition

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/762903.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号