kafka面试篇

news2024/9/21 14:46:55

消息队列的作用：异步、削峰填谷、解耦

高可用，几乎所有相关的开源软件都支持，满足大多数的应用场景，尤其是大数据和流计算领域，

  • kafka高效，可伸缩，消息持久化。支持分区、副本和容错。

  • 对批处理和异步处理做了大量的设计，因此Kafka可以得到非常高的性能。

  • 每秒处理几十万异步消息，如果开启了压缩，可以达到每秒处理2000w消息的级别。

  • 但是由于是异步的和批处理的，延迟也会高。

  • Producer API：允许应用程序将记录流发布到一个或多个Kafka主题。

  • Consumer API：允许应用程序订阅一个或多个主题并处理为其生成的记录流。

  • Streams API：允许应用程序充当流处理器，将输入流转换为输出流。

kafka的数据单元称为消息，可以将消息看成是数据库里的一个“数据行”或一条“记录”。

批次

为了提高效率，消息被分批次写入kafka，提高吞吐量却加大了响应时间。

主题Topic

通过主题进行分类，类似数据库中的表。

分区Partition

Topic可以被分成若干分区分布于kafka集群中，方便扩容

单个分区内是有序的，partition设置为1，才可以保证全局有序。

副本Replicas

每个主题被分为若干个分区，每个分区有多个副本。

生产者Producer

生产者在默认情况下把消息均衡地分布到主题的所有分区上：

  • 直接指定消息的分区
  • 根据消息的key散列取模得出分区
  • 轮询指定分区

消费者Comsumer

消费者通过偏移量来区分已经读过的消息，从而消费消息。将每个分区最后读取的消息偏移量保存到Zookeeper 或Kafka上，如果消费者关闭或重启，它的读取状态不会丢失。

消费组ComsumerGroup

消费组保证每个分区只能被一个消费者使用，避免重复消费。如果群组内一个消费者失效，消费组的其他消费者可以接管失效消费者的工作再平衡，重新分区。

节点Broker

连接生产者和消费者，单个broker可以轻松处理数千个分区以及每秒百万级的消息量。

  • broker接收来自生产者的消息，为消息设置偏移量，并提交消息到磁盘保存。
  • broker为消费者提供服务，响应读取分区的请求，返回已经提交到磁盘上的消息。

集群

每个分区都有一个首领，当分区被分配给多个broker时，会通过首领进行分区复制。 

生产者offset

消息写入的时候，每一个分区都有一个offset，即每个分区的最新最大的offset。

消费者offset

不用消息组中的消费者可以针对一个分区存储不同的offset，互不影响。

LogSegment

  • 一个分区由多个LogSegment组成，

  • 一个LogSegment由.log /.index / .timeindex组成

  • .log追加时顺序写入的，文件名是以文件中第一条message的offset来命名的
  • .index进行日志删除时和数据查找的时候可以快速定位。
  • .timeStamp则根据时间戳查找对应的偏移量。

kafka的优点

  • 高吞吐量：单机每秒处理几十上百万的消息量。即使存储了TB级消息，也保持稳定的性能。

    • 零拷贝：减少内核态到用户态的拷贝，磁盘通过sendfile实现DMA 拷贝Socket buffer

    • 顺序读写：充分利用磁盘顺序读写的超高性能

    • 页缓存mmap，将磁盘文件映射到内存, 用户通过修改内存就能修改磁盘文件。

  • 高性能：单节点支持上千个客户端，并保证零停机和零数据丢失。
  • 持久化：将消息持久化到磁盘，通过将数据持久化到硬盘以及replication防止数据丢失。

  • 分布式系统：易扩展。所有的组件均为分布式的，无需停机即可扩展机器。

  • 可靠性 ： Kafka是分布式，分区，复制和容错的。

kafka的应用场景

  • 日志收集：用Kafka可以收集各种服务的Log，通过大数据平台进行处理；

  • 消息系统：解耦生产者和消费者，缓存消费等；
  • 用户活动跟踪：Kafka经常被用来记录Web用户或者App用户的各种活动，如浏览网页、搜索、点击等活动，这些活动信息被各个服务器发布到kafka的topic中，然后消费者通过订阅这些Topic来做运营数据的实时的监控分析，也可以保存到数据库；

生产消费基本流程

1.Producer创建时，会创建一个sender线程并设置为守护线程

2.生产的消息先经过拦截器-->序列化器-->分区器，然后将消息缓存在缓冲区。

3.批次发送的条件是：缓冲区数据大小达到batch.size或者linger.ms达到上限。

4.批次发送后，发往制定分区，然后分区落盘到broker。

  • acks=0只需要将消息放到缓冲区，就认为消息已经发送完成。
  • acks=1表示消息只需要写入主分区即可。在该情形下，如果主分区收到消息确认之后就会宕机了，而副本分区还没来得及同步该消息，则该消息丢失。
  • acks=all(默认)首领分区会等待所有的ISR副本分区确认记录。该处理保证了只要有一个isr副本分区存活，消息就不会丢失。

5.如果生产者配置了retrires参数大于0并且未收到确认，那么客户端会对该消息进行重试。

6.落盘到broker成功，赶回生产元数据给生产者。

Leader选举

  • kafka会在zookeeper上针对每个topic维护一个称为ISR(in-sync-replica)的集合；
  • 当集合中副本都跟leader中的副本同步了之后，kafka才会认为消息已提交；

  • 只有这些跟Leader保持同步的Follower才应该被选作新的Leader；

  • 假设某个topic有N+1个副本，kafka可以容忍N个服务器不可用，冗余度较低。

  • 如果ISR中的副本都丢失了，则：

    • 可以等待ISR中的副本任何一个恢复，接着对外提供服务，需要时间等待。
    • 从OSR中选择出一个副本做Leader副本，此时会造成数据丢失；

副本消息同步

 首先，Follower发送FETCH请求给leader。接着Leader 会读取底层日志文件中的消息数据，再更新它内存中的Follwer副本的LEO值，更新为FETCH请求中的 fetchOffset值。最后，尝试更新分区高水位值。Follower接收到FETCH响应之后，会把消息写入到底层日志，接着更新 LEO 和 HW 值。

相关概念：LEO和HW        

  • LEO：即日志末端位移（log end offset），记录了该副本日志中下一条消息的位移值，如果LEO=10,那么表示该副本保存了10条消息，位移值范围是【0,9】
  • HW：水位值HW(high watermark)即已备份位移。对于同一个副本对象而言，其HW值不会大于LEO值。小于等于HW值的所有消息都被认为是“已备份”的（replicated）。

Rebalance

  • 组成员数量发生变化
  • 订阅主题数量发生变化
  • 订阅主题的分区数发生变化

     leader选举完成后，当以上三种情况发生时，leader根据配置的RangeAssignor算法开始分配消费方案，即哪个consumer负责消费哪些topic的哪些partiiton。一旦完成分配，leader会将这个方案封装进SyncGroup请求中发给coordinator，非leader也会发SyncGroup请求，只是内容为空。coordinator接收到分配方案之后会把方案塞进SyncGroup的response中发给各个consumer。这样组内的所有成员就都知道自己应该消费哪些分区了。

分区分配算法RangeAssignor

  • 原理是按照消费者总数和分区总数进行整除运算平均分配给所有的消费者；
  • 订阅topic的消费者按照名称的字典序排序，分均分配，剩下的字典序从前往后分配；

如何查看偏移量为23的消息？

   通过查询跳跃表ConcurrentSkipListMap，定位到在00000000000000000000.index ，通过二分法在偏移量索引文件中找到不大于 23 的最大索引项，即offset 20 那栏，然后从日志分段文件中的物理位置为320开始顺序查找偏移量为23的消息。

切分文件

  • 大小分片 当前日志分段文件的大小超过了 broker 端参数 log.segment.bytes 配置的值；

  • 时间分片 当前日志分段中消息的最大时间戳与系统的时间戳的差值大于log.roll.ms配置的值；

  • 索引分片 偏移量或时间戳索引文件大小达到broker端 log.index.size.max.bytes配置的值；

  • 偏移分片 追加的消息的偏移量与当前日志分段的偏移量之间的差值大于 Integer.MAX_VALUE；

幂等性

保证在消息重发的时候，消费者不会重复处理。即使在消费者收到重复消息的时候，重复处理，也要保证最终结果的一致性。所谓幂等性，数学概念就是：f(f(x)) = f(x) 

幂等性如何实现？

添加唯一ID，类似于数据库的主键，用于唯一标记一个消息。

ProducerID：#在每个新的Producer初始化时，会被分配一个唯一的PIDSequenceNumber：
#对于每个PID发送数据的每个Topic都对应一个从0开始单调递增的SN值

Leader选举

1.使用Zookeeper的分布式锁选举控制器，并在节点加入集群或退出集群时通知控制器。

2.控制器负责在节点加入或离开集群时进行分区leader选举。

3.控制器使用epoch忽略小的纪元来避免脑裂：两个节点同时认为自己是当前的控制器。

可用性

  • 创建Topic的时候可以指定 --replication-factor 3 ，表示不超过broker的副本数

  • 只有Leader是负责读写的节点，Follower定期地到Leader上Pull数据。
  • ISR是Leader负责维护的与其保持同步的Replica列表，即当前活跃的副本列表。如果一个Follower落后太多，Leader会将它从ISR中移除。选举时优先从ISR中挑选Follower。
  • 设置acks=all。Leader收到了ISR中所有Replica的 ACK，才向Producer发送ACK。

面试题

1）线上问题rebalance

因为集群架构变动导致的消费组内重平衡，如果kafka集群内节点较多，比如数百个，那重平衡可能会耗时导致数分钟到数小时，此时kafka基本处于不可用状态，对kafka的TPS影响极大。

产生的原因：

  • 组成员数量发生变化

  • 订阅主题数量发生变化

  • 订阅主题的分区数发生变化

     组成员崩溃和组成员主动离开是两个不同的场景。因为在崩溃时成员并不会主动的告知coordinator，coordinator有可能需要一个完整的session.timeout周期(心跳周期）才能检测到这种崩溃，这必然会造成consumer的滞后。主动离开是主动发起rebalance，而崩溃是被动发起rebalance。

解决方案：

加大超时时间 session.timout.ms=6s
加大心跳频率 heartbeat.interval.ms=2s
增长推送间隔 max.poll.interval.ms=t+1 minutes

2）ZooKeeper 的作用

目前，Kafka 使用 ZooKeeper 存放集群元数据、成员管理、Controller 选举，以及其他一些管理类任务。之后，等 KIP-500 提案完成后，Kafka 将完全不再依赖于 ZooKeeper。

  • 存放元数据是指主题分区的所有数据都保存在ZooKeeper，其他“人”都要与它保持对齐。
  • 成员管理是指Broker节点的注册，注销以及属性变更等。
  • Controller 选举是指选举集群 Controller，包括但不限于主题删除，参数配置等。

一言以蔽之:KIP-500 ，是使用社区自研的基于 Raft 的共识算法，实现 Controller 自选举。

同样是存储元数据，这几年基于Raft算法的etcd认可度越来越高。

3）Replica副本的作用

kafka只有Leader副本才能对外提供读写服务，响应 Clients 端的请求。Follower副本只是采取拉（PULL）的方式，被动地同步Leader副本中的数据，并且在 Leader 副本所在的 Broker 宕机后，随时准备应聘Leader 副本。（Follower --> Leader）

  • 自 Kafka 2.4 版本开始，社区可以通过配置参数，允许 Follower 副本有限度地提供读服务。

  • 之前确保一致性的主要手段是高水位机制， 但高水位值无法保证 Leader 连续变更场景下的数据一致性，因此，社区引入了 Leader Epoch 机制，来修复高水位值的弊端。

4）为什么不支持读写分离?

  • 自 Kafka 2.4 之后，Kafka 提供了有限度的读写分离。

  • 场景不适用。读写分离适用于读负载很大，而写操作相对不频繁的场景。
  • 同步机制。Kafka 采用 PULL 方式实现 Follower 的同步，同时复制延迟较大。

5）如何防止重复消费

  • 代码层面每次消费需提交offset;
  • 通过Mysql的唯一键约束，结合Redis查看id是否被消费，存Redis可以直接使用set方法；
  • 量大且允许误判的情况下，使用布隆过滤器也可以。

6）如何保证数据不会丢失

  • 生产者生产消息可以通过comfirm配置ack=all解决；（生产端）

  • Broker节点同步过程中leader宕机可以通过配置ISR副本+重试解决；（Broker）
  • 消费者丢失可以关闭自动提交offset功能，系统处理完成时提交offset；（消费端）

7）如何保证顺序消费

  • 设置单topic，单partiiton，单consumer，吞吐量底，不推荐；
  • 如只需保证单key有序，为每个key单独申请内存queue，每个线程分别消费一个内存queue 即可，这样就能保证单key（例如用户id、活动id）顺序性。

8）线上如何解决积压消费

  • 修复consumer，使其具备消费能力，并且扩容N台；
  • 写一个分发的程序，将Topic均匀分发到临时Topic中；
  • 同时启N台消费者consumer，消费不同的临时Topic

9）如何避免消息积压

  • 提高消费并行度
  • 批量消费
  • 减少组件IO的交互次数
  • 优先级消费
if (maxOffset - curOffset > 100000) {  // TODO 消息堆积情况的优先处理逻辑  // 未处理的消息可以选择丢弃或者打日志  return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}// TODO 正常消费过程return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;

10）如何设计消息队列

需要支持快速水平扩容，broker+ partition，partition放在不同的机器上，增加机器时将数据根据topic做迁移，分布式需要考虑一致性，可用性，分区容错性。

  • 一致性：生产者的消息确认、消费者的幂等性、Broker的数据同步；

  • 可用性：数据如何保证不丢不重、数据如何持久化、持久化时如何读写；

  • 分区容错：采用何种选举机制、如果进行多副本同步；
  • 海量数据：如何解决消息积压，海量Topic性能下降；

性能上，可以借鉴时间轮、零拷贝、IO多路复用、顺序读写、压缩批处理。

参考文章：

这些年背过的面试题——Kafka篇

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1535994.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

python四川火锅文化网站的设计与实现flask-django-php-nodejs

python四川火锅文化网站的设计与实现flask-django-php-nodejs

四川火锅文化网站的目的是让使用者可以更方便的将人、设备和场景更立体的连接在一起。能让用户以更科幻的方式使用产品，体验高科技时代带给人们的方便，同时也能让用户体会到与以往常规产品不同的体验风格。 与安卓，iOS相比较起来，…
阅读更多...
Android ViewPager不支持wrap_content的原因

Android ViewPager不支持wrap_content的原因

文章目录 Android ViewPager不支持wrap_content的原因问题源码分析解决 Android ViewPager不支持wrap_content的原因 问题 <androidx.viewpager.widget.ViewPagerandroid:id"id/wrap_view_pager"android:layout_width"match_parent"android:layout_he…
阅读更多...
QT6 android下配置文件打包到APK

QT6 android下配置文件打包到APK

一.遇到问题 用QT做android开发&#xff0c;生成的apk文件默认不包含程序配置文件和png文件&#xff0c;导致程序在android上无法读取必要的参数和logo&#xff0c;本文主要解决这个问题&#xff0c;并详细讲述QT android 的apk程序打包流程。 二.APK打包流程 1.如何生成APK 当…
阅读更多...
STM32关于使用定时器触发ADC转换的理解

STM32关于使用定时器触发ADC转换的理解

以STM32 ADC的常规通道为例&#xff08;注入通道类似&#xff09;&#xff1a; 如上图&#xff0c;STM32 ADC的常规通道可以由以上6个信号触发任何一个&#xff0c;我们以使用TIM2_CH2触发ADC1&#xff0c;独立模式&#xff0c;每次仅测一条通道&#xff0c;则ADC的配置如下&am…
阅读更多...
2023年最受欢迎的编程语言排行榜 —— Python位居榜首，但对你来说未必是最佳选择

2023年最受欢迎的编程语言排行榜 —— Python位居榜首，但对你来说未必是最佳选择

本文的编程语言热度统计数据来自《IEEE Spectrum》&#xff0c;《IEEE Spectrum》杂志是IEEE&#xff08;美国电气电子工程师学会&#xff09;的旗舰出版物&#xff0c;探讨了新技术的发展、应用和影响。它预测工程、科学和技术的趋势&#xff0c;并为理解、讨论和领导这些领域…
阅读更多...
扩容分区和文件系统（Linux）

扩容分区和文件系统（Linux）

在ECS控制台上扩容云盘容量后&#xff0c;对应分区和文件系统并未扩容&#xff0c;您还需要进入ECS实例内部继续扩容云盘的分区和文件系统&#xff0c;将扩容部分的容量划分至已有分区及文件系统内&#xff0c;使云盘扩容生效。本文为您介绍如何通过两个步骤完成Linux实例云盘的…
阅读更多...
牛客NC403 编辑距离为一【中等 模拟法 Java,Go,PHP】

牛客NC403 编辑距离为一【中等 模拟法 Java,Go,PHP】

题目 题目链接&#xff1a; https://www.nowcoder.com/practice/0b4b22ae020247ba8ac086674f1bd2bc 思路 注意&#xff1a;必须要新增一个&#xff0c;或者删除一个&#xff0c;或者替换一个&#xff0c;所以不能相等1.如果s和t相等&#xff0c;返回false,如果s和t长度差大于1…
阅读更多...
搜维尔科技：利用增强现实改进检验和质量控制流程

搜维尔科技：利用增强现实改进检验和质量控制流程

直接在工作环境中显示数字指令 DELMIA 质量检查增强体验通过工作环境中的数字指令指导操作员完成检查过程&#xff0c;从而有效地识别、鉴定和报告不合格项。使用增强现实可以显着提高质量控制和检查过程的准确性和速度。由于技术人员可以访问实时信息&#xff0c;因此他们会减…
阅读更多...
NX二次开发——获取当前dll的全路径，上一级路径和名称

NX二次开发——获取当前dll的全路径，上一级路径和名称

在nx二次开发中经常会用到dll的全路径&#xff0c;上一级路径和名称&#xff0c;这里我对其进行封装&#xff0c;方便以后调用。 关键代码&#xff1a; //头文件 #include <Windows.h> #include <atlbase.h>//获取当前dll所在的文件夹(mode:0-全路径名&#xff0…
阅读更多...
K8s-网络原理-中篇

K8s-网络原理-中篇

引言 本文是《深入剖析 K8s》的学习笔记&#xff0c;相关图片和案例可从https://github.com/WeiXiao-Hyy/k8s_example中获取&#xff0c;欢迎 ⭐️! 上篇主要介绍了 Flannel 插件为例&#xff0c;讲解了 K8s 里容器网络和 CNI 插件的主要工作原理。还有一种“纯三层”的网络方…
阅读更多...
数值分析（三） Lagrange（拉格朗日）插值法及Matlab代码实现

数值分析（三） Lagrange（拉格朗日）插值法及Matlab代码实现

目录 前言一、Lagrange&#xff08;拉格朗日&#xff09;插值1. 线性插值2. 抛物插值3. 拉格朗日插值多项式 二、Lagrange插值算法及matlab代码1. Lagrange 插值算法matlab实现2 实例3. 线性插值示意图代码4. 抛物插值示意图代码 三、总结四、插值法专栏 前言 本篇为插值法专栏…
阅读更多...
C语言内存函数之 memcmp函数

C语言内存函数之 memcmp函数

memcmp函数的记忆&#xff1a;mem表示内存&#xff0c;单位是字节&#xff0c;表示以单位字节来进行操作&#xff1b;头文件是string.h&#xff0c;cmp是compare的缩写&#xff0c;表示比较。总的意思就是在规定的内存下以字节为单位一个字节一个字节的进行比较。 memcmp函数的…
阅读更多...
C语言基础练习——Day15

C语言基础练习——Day15

目录 选择题 编程题 寻找奇数 寻找峰值 选择题 1、有如下代码&#xff0c;则*(p[0]1)所代表的数组元素是 int a[3][2] {1, 2, 3, 4, 5, 6}, *p[3]; p[0] a[1]; A a[0][1]B a[1][0]C a[1][1]D a[1][2] 答案&#xff1a;C &#x1f4a1; 解析&#xff1a; 本题定义了一个3行2列…
阅读更多...
怎样在一台电脑安装多个版本的JDK并切换使用？一篇文章教会你所有细节

怎样在一台电脑安装多个版本的JDK并切换使用？一篇文章教会你所有细节

目录 1. 下载安装JDK版本 2. 配置环境变量 2. 1 配置环境变量的步骤 2.2 需要注意的细节点 2.3 JDK8&#xff0c;11&#xff0c;17版本切换测试 1. 下载安装JDK版本 a. JDK8 下载链接&#xff1a; Java Downloads | Oraclehttps://www.oracle.com/java/technologies/dow…
阅读更多...
蓝桥杯刷题（十三）

蓝桥杯刷题（十三）

1.煤球数目 代码 cnt ans 0 start 1 a [] while cnt<100:ansstartstart 1t ansstartcnt1a.append(ans) print(sum(a))2.奖券数目 代码 def f(x)->bool:while x:if x%104:return Falsex//10return True ans 0 for i in range(10000,100000):if f(i):ans1 print(a…
阅读更多...
土地利用的时序建模

土地利用的时序建模

1、LULC 模型的现状 最近的土地利用和土地覆盖 (LULC) 建模进展来自两种方法。 在一种方法中&#xff0c;现有模型适用于 LULC&#xff0c;而在另一种方法中&#xff0c;模型架构是针对 LULC 明确设计的。 随着大型基础模型的兴起&#xff0c;人工智能和深度学习取得了重大进…
阅读更多...
广告增量实时索引构建实践

广告增量实时索引构建实践

本期作者 1.前言 在广告检索系统中&#xff0c;增量索引&#xff08;实时索引&#xff09;是一类常见的技术&#xff0c;用于使广告信息的变更及时生效。其中一种主要的思路即由检索系统消费广告更新数据流&#xff0c;实时更新内存索引&#xff0c;对此行业中已有很多优秀方案…
阅读更多...
Linux: 线程安全

Linux: 线程安全

Linux 线程共享了进程的资源(地址空间, 页表等), 多个线程同时访问同一个资源就可能产生问题:数据竞争 临界资源: 多个线程共享的资源临界区: 访问临界资源的区域互斥: 任何时刻, 只有一个执行流能进入临界区同步: 以一定顺序访问临界资源原子性: 要么完成, 玩么未完成 锁 死…
阅读更多...
【Leetcode每日一题】 递归 - Pow(x, n)（难度⭐⭐）（40）

【Leetcode每日一题】 递归 - Pow(x, n)（难度⭐⭐）（40）

1. 题目解析 题目链接&#xff1a;50. Pow(x, n) 这个问题的理解其实相当简单&#xff0c;只需看一下示例&#xff0c;基本就能明白其含义了。 2.算法原理 在这个算法中&#xff0c;递归函数的任务是求出 x 的 n 次方。那么&#xff0c;这个函数是怎么工作的呢&#xff1f;它…
阅读更多...
Linux_开发工具_yum_vim_gcc/g++_gdb_make/makefile_进度条_git_2

Linux_开发工具_yum_vim_gcc/g++_gdb_make/makefile_进度条_git_2

文章目录 一、Linux软件包管理器yum1. centos7 中安装软件方式2.安装&#xff0c;卸载&#xff0c;查看3.yum源4.安装lrzsz5.安装扩展源 二、Linux编辑器-vim1.安装vim2.vim的三种模式3.命令模式-文本批量化操作4.vim配置 三、Linux编译器-gcc/g使用1.安装2.gcc如何完成1、 预处…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023