当前位置: 首页 > article >正文

kafka面试题part-3

6、kafka如何知道哪个消费者消费哪个分区?

生产者把数据发送给各个分区,每个broker节点都有一个coordinator(协调器),消费者组对分区进行消费,到底哪个消费者消费哪个分区呢?首先groupId对50取模,看最后的结果是哪个分区节点,假如是1分区,那么1分区的协调器就是本次消费者组的老大,消费者纷纷向该协调器进行注册,协调器从中随机选择一个消费者作为本次消费的Leader,然后把本次消费的具体情况发送给Leader,让其制定一个消费计划(就是哪个消费者消费哪个分区),然后Leader发送给协调器,协调器再进行群发,将计划公布,各个消费者按照这个计划进行消费。

7、kafka消费者的消费分区策略有哪些,默认是个?

Kafka有四种主流的分区分配策略:

Range、RoundRobin(轮询)、Sticky(粘性)、CooperativeSticky(配合的粘性)。

默认策略是Range + CooperativeSticky。Kafka可以同时使用多个分区分配策略。

 


http://www.kler.cn/a/390870.html

相关文章:

  • 24/11/13 算法笔记<强化学习> DQN算法
  • Coggle数据科学 | RAG编码模型对比:谁与OpenAI最为相似?
  • SpringSecurity源码中核心类
  • GitLab 如何跨版本升级?
  • 【css】html里面的图片宽度设为百分比,高度要与宽度一样
  • 哪款开放式耳机好用?5款实力出众的开放式耳机按头安利!
  • 发包人一直恶意拖延审计,施工人如何破局?
  • 信息安全工程师(82)操作系统安全概述
  • MVVM前端开发模型,怎么快速定位问题
  • 库打包工具 rollup
  • Chromium127编译指南 Linux篇 - 编译前环境搭建(一)
  • 基于深度卷积二元分解网络的齿轮和轴承故障特征提取方法
  • 【LeetCode】【算法】11. 盛最多水的容器
  • C 语言学习-03【输入与输出】
  • 使用 Umami 部署博客分析工具
  • 达梦数据库配置本地守护
  • Execution failed for task ‘:app:compileDebugKotlin‘. 问题解决。
  • java数据结构与算法:栈
  • Unity3D UI 双击和长按
  • uni-app上拉加载更多⑩
  • 掌握 Java 集合框架:从基础到高级的全面指南
  • 量化交易系统开发-实时行情自动化交易-3.4.2.Okex行情交易数据
  • MySQL 常见时间字段设置
  • class com.alibaba.fastjson2.JSONObject cannot be cast to class com.ruoyi.sys
  • Redhat8.6安装JDK1.8
  • Docker--Docker是什么和对Docker的了解