热门标签
热门文章
- 1Nginx （一）简介和基本的功能作用_xxnnx
- 2ACL访问控制列表_三层acl编号范围是多少
- 3牛客练习赛73 D离别 线段树+离线_c++ 出现的次数大于等于 k的区间[l,r]
- 4记一次博客评论回复实现遇到的bug_document.body.removechild
- 5ElementUI快速入门_element ui
- 6PySide6环境搭建、PyCharm外部工具设置_ubuntu pyside6
- 7自己画一块ESP32-C3 的开发板（立创EDA）（PCB到手）_esp32-c3mini-ch340原理图模块设计
- 8智慧应急：构建全方位、立体化的安全保障网络
- 9LeetCode 2120.执行所有后缀指令
- 10Vue3_2024_1天【Vue3创建和响应式，对比Vue2】
当前位置: article > 正文
消息队列-Kafka-基础架构
作者：weixin_40725706 | 2024-03-05 17:51:28
赞
踩
消息队列-Kafka-基础架构
基础架构
上面这张图类比RocketMQ 相当于对一个主题进行了分区（类似于RockeMQ 消息队列），每个分区存储到不同的Broker。在发送消息的时候都是发送到主分区。如果一台Broker由于其它节点备份了挂掉节点的数据，所以可以继续进行消费，从而保证了整个集群的高可用性。
在进行消费数据的时候：
- 如果消费者组中的消费者数量等于分区数量，则消费者组里面的每个消费是分别订阅一个分区的。
- 如果消费组中的消费者数量小于分区的数量， 这个时候肯定有一个消费者需要消费多一个分区的消息。
- 如果消费者组中的消费者比分区数还多，则存在一个消费者没有数据的情况，这个时候这个消费者处于空闲状态。
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/weixin_40725706/article/detail/192809
推荐阅读
相关标签
