首页 > 其他分享 >Kafka面试题总结

Kafka面试题总结

时间:2024-11-07 11:43:59浏览次数:6  
标签:总结 面试题 消费 kafka 如何 Kafka 数据 Leader

1、kafka消息发送的流程?

2、Kafka 的设计架构你知道吗?

3、Kafka 分区的目的?

4、你知道 Kafka 是如何做到消息的有序性?

5、ISR、OSR、AR 是什么?

6、Kafka 在什么情况下会出现消息丢失

7、怎么尽可能保证 Kafka 的可靠性

8、Kafka中如何做到数据唯一,即数据去重?

9、生产者如何提高吞吐量?

10、zk在kafka集群中有何作用

11、简述kafka集群中的Leader选举机制

12、kafka是如何处理数据乱序问题的。

13、kafka中节点如何服役和退役

14、Kafka中Leader挂了,Follower挂了,然后再启动,数据如何同步?

15、kafka中初始化的时候Leader选举有一定的规律,如何打破这个规律呢?

16、kafka是如何做到高效读写

17、Kafka集群中数据的存储是按照什么方式存储的?

18、kafka中是如何快速定位到一个offset的。

19、简述kafka中的数据清理策略。

20、消费者组和分区数之间的关系是怎样的?

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

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

23、kafka中的消费者,他们的偏移量存储在哪里?

24、kafka中数据挤压太多,怎么办?(提高消费者的效率)

25、Kafka中的数据在消费过程中,有漏消费和重复消费的情况,怎么办?

26、kafka中的数据已经消费过的数据,是否可以再次消费?怎么做?

标签:总结,面试题,消费,kafka,如何,Kafka,数据,Leader
From: https://blog.csdn.net/2301_79362607/article/details/143590760

相关文章

  • kafka 相关操作命令
    /home/kafka/config/kafka_client_producer_jaas.conf文件为对应集群的鉴权配置文件,例如sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule\requiredusername="dev-user"password="devuser@123";security.protocol=SASL_PLAINTEXTsasl.mec......
  • Java面试系列-SpringCloud面试题20道,服务注册与发现,断路器,智能路由,熔断,追踪,网关,调用,限
    文章目录1.SpringCloud是什么?2.SpringCloud中的服务注册与发现是如何工作的?3.SpringCloud中的配置管理是如何工作的?4.SpringCloud中的断路器(Hystrix)是如何工作的?5.SpringCloud中的智能路由(Zuul)是如何工作的?6.SpringCloud中的服务熔断(Resilience4j)......
  • 程序员面试题目之栈的用法
    【题目】        实现一个特殊的栈,在实现栈的基本功能的基础上,再实现返回栈中最小元素的操作。【要求】        1.pop、push、getMin操作的时间复杂度都是O(1)。        2.设计的栈类型可以使用现成的栈结构。【解答】......
  • Java面试系列-MySQL面试题20道,InnoDB,索引类型,事务隔离级别,锁机制,MVCC,主从复制,慢查询,分
    文章目录1.MySQL中的InnoDB和MyISAM存储引擎有什么区别?2.MySQL中的索引类型有哪些?3.MySQL中的索引是如何工作的?4.MySQL中的事务隔离级别有哪些?5.MySQL中的锁机制有哪些?6.MySQL中的MVCC(多版本并发控制)是如何工作的?7.MySQL中的主从复制是如何工作的?8.MySQL中的分区......
  • Kafka在后端开发中的应用场景是什么?
    Kafka在后端开发中的应用场景非常广泛,主要体现在以下几个方面:异步处理:Kafka可以用于异步处理消息,使得各个模块之间的处理流程可以独立进行,不需要等待前一个流程完成即可开始下一个流程。消息系统(Messaging) :Kafka可以替代传统的消息代理,用于解耦生产者和消费者之间的关系,缓......
  • 2024-2025-1 20231420《计算机基础与程序设计》第六周总结
    课程答疑实验相关1.实验环境的搭建对同学们来说相对陌生,有时会出现操作错误、字母输错等情况。建议:可以多浏览实验指导书,熟悉操作。2.C语言部分算法没能掌握透彻,在实现功能时不知道怎么写代码。建议:可以多进行练习,在写代码的过程中加深理解。3.不会绘画流程图。建议:首先理......
  • LeetCode题练习与总结:组合总和 Ⅳ --377
    一、题目描述给你一个由 不同 整数组成的数组 nums ,和一个目标整数 target 。请你从 nums 中找出并返回总和为 target 的元素组合的个数。题目数据保证答案符合32位整数范围。示例1:输入:nums=[1,2,3],target=4输出:7解释:所有可能的组合为:(1,1,1,1)......
  • LeetCode题练习与总结:有序矩阵中第 K 小的元素--378
    一、题目描述给你一个 nxn 矩阵 matrix ,其中每行和每列元素均按升序排序,找到矩阵中第 k 小的元素。请注意,它是 排序后 的第 k 小元素,而不是第 k 个 不同 的元素。你必须找到一个内存复杂度优于 O(n^2) 的解决方案。示例1:输入:matrix=[[1,5,9],[10,11......
  • 深入理解 Kafka 的消息持久化机制
    在分布式系统中,消息队列扮演着至关重要的角色。Kafka作为一种高性能、高可靠的分布式消息队列系统,其强大的消息持久化机制是保证数据可靠性的关键。那么,什么是Kafka的消息持久化机制呢?一、Kafka简介Kafka是一个开源的分布式事件流平台,最初由LinkedIn公司开发,后来成为Apac......
  • 刷题总结——动态规划
    总论怎么求解?回溯记忆化搜索递推(方便进行空间复杂度优化)求什么?方案数最大值最小值状态方程对应关系:转移状态的定义(回溯入口)边界条件(边界状态如何递推得到其实状态,回溯的终止条件)如果递推公式是求最小,边界初始化成INT_MAX_*如果递推公式求最大,边界为0或1如......