kafka面试题part-3

news/2024/11/15 9:30:22/

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

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

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

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

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

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

 


http://www.ppmy.cn/news/1547177.html

相关文章

掌握ECMAScript模块化:构建高效JavaScript应用

标题:掌握ECMAScript模块化:构建高效JavaScript应用 在现代JavaScript开发中,模块化编程已经成为一个不可或缺的概念。它帮助我们管理和组织代码,提高代码的复用性和可维护性。本文将深入探讨ECMAScript模块化的实现,…

基于OpenFOAM和深度学习驱动的流体力学计算与应用

在深度学习与流体力学深度融合的背景下,科研边界不断拓展,创新成果层出不穷。从物理模型融合到复杂流动模拟,从数据驱动研究到流场智能分析,深度学习正以前所未有的力量重塑流体力学领域。近期在Nature和Science杂志上发表的深度学…

科研绘图系列:R语言极坐标柱状图(barplot)

文章目录 介绍加载R包数据下载导入数据数据预处理准备画图数据画图合并图系统信息介绍 R语言极坐标柱状图 加载R包 library(tidyverse) library(ggplot2) library(cowplot) library(gridExtra) library(caret) library(matrixStats

【MYSQL】触发器

一、触发器介绍 在DML操作后可能会在前或后触发到提前定义好的SQL集合,使用OLD和NEW引用触发器中变化的内容。对于MYSQL只支持行级触发器。 二、如何使用 创建触发器,设置在dml操作前还是后触发,然后作用在哪张表上,设置行级触发器&#xff0…

前端呈现效果:鱼眼相机城市环境图像分割

鱼眼相机城市环境图像分割系统源码&数据集分享 [yolov8-seg-SPDConv&yolov8-seg-vanillanet等50全套改进创新点发刊_一键训练教程_Web前端展示] 1.研究背景与意义 项目参考ILSVRC ImageNet Large Scale Visual Recognition Challenge 项目来源AAAI G…

RabbitMQ-死信队列(golang)

1、概念 死信(Dead Letter),字面上可以理解为未被消费者成功消费的信息,正常来说,生产者将消息放入到队列中,消费者从队列获取消息,并进行处理,但是由于某种原因,队列中的…

Hive的远程模式

1、创建临时目录 [rootbigdata01 ~]# cd /opt/installs/hive/ [rootbigdata01 hive]# mkdir iotmp [rootbigdata01 hive]# chmod 777 iotmp 2、前期准备工作 hive-site.xml<!--Hive工作的本地临时存储空间--> <property><name>hive.exec.local.scratchdir…

前端(1)——快速入门HTML

参考&#xff1a; W3school 1. HTML 我使用的是vs code&#xff0c;在使用之前&#xff0c;先安装以下几个插件&#xff1a; Auto Rename TageHTML CSS SupportLive Server 1.1 HTML标签 HTML全称是 Hypertext Markup Language(超文本标记语言) HTML通过一系列的标签(也称为…