面试官:知道时间轮算法吗?在Netty和Kafka中如何应用的?为什么不用Timer、延时线程池?(上)

面试官:知道时间轮算法吗?在Netty和Kafka中如何应用的?为什么不用Timer、延时线程池?(上)

大家好,我是yes。最近看 Kafka 看到了时间轮算法,记得以前看 Netty 也看到过这玩意,没太过关注。今天就来看看时间轮到底是什么东西。为什么要用时间轮算法来实现延迟操作?延时操作 Java 不是提供了 Timer 么?还有 DelayQueue 配合线程池或者 ScheduledThrea...

面试官:说说Kafka控制器事件处理全流程(下)

面试官:说说Kafka控制器事件处理全流程(下)

UpdateMetadataRequest更新Broker上的元数据。Controller事件处理线程会把事件封装成对应的请求,然后将请求写入对应的Broker的请求阻塞队列,然后RequestSendThread不断从阻塞队列中获取待发送的请求。先解释下controllerBrokerStateI...

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图
面试官:说说Kafka控制器事件处理全流程(上)

面试官:说说Kafka控制器事件处理全流程(上)

前言大家好,我是 yes。这是Kafka源码分析第四篇文章,今天来说说 Kafka控制器,即 Kafka Controller。源码类的文章在手机上看其实效果很差,这篇文章我分为两部分,第一部分就是直接图文来说清整个 Kafka 控制器事件处理全流程,然后再通过Controller选举流程进行一波源...

面试官:说说Kafka处理请求的全流程

面试官:说说Kafka处理请求的全流程

大家好,我是 yes。这是我的第三篇Kafka源码分析文章,前两篇讲了日志段的读写和二分算法在kafka索引上的应用今天来讲讲 Kafka Broker端处理请求的全流程,剖析下底层的网络通信是如何实现的、Reactor在kafka上的应用。再说说社区为何在2.3版本将请求类型划分成两大类,又是如何...

面试官:Kafka索引设计有什么亮点?

面试官:Kafka索引设计有什么亮点?

前言其实这篇文章只是从Kafka索引入手,来讲述算法在工程上基于场景的灵活运用。单单是因为看源码的时候有感而写之。索引的重要性索引对于我们来说并不陌生,每一本书籍的目录就是索引在现实生活中的应用。通过寥寥几页纸就得以让我等快速查找需要的内容。冗余了几页纸,缩短了查阅的时间。空间和时间上的互换,包含着...

一次面试引发的Kafka源码之旅

一次面试引发的Kafka源码之旅

引子之所以写这篇文章是因为之前面试时候被面试官问到(倒)了,面试官说:“你说你对Kafka比较熟?看过源码? 那说说kafka日志段如何读写的吧?”我心里默默的说了句 “擦...我说看过一点点源码,不是亿点点。早知道不提这句了!”,那怎么办呢,只能回家等通知了啊。但是为了以后找回场子&...

大厂面试官竟然这么爱问Kafka,一连八个Kafka问题把我问蒙了? 

在面试的时候,发现很多面试官特别爱问Kafka相关的问题,这也不难理解,谁让Kafka是大数据领域中消息队列的唯一王者,单机十万级别的吞吐量,毫秒级别的延迟,这种天生的分布式消息队列,谁能不爱?在最近的一场面试中,有个面试官看到简历中的项目上写Kafka了,...

面试题:Kafka如何保证高可用?有图有真相

上次面试多次被问到一个问题:❝Kafka如何保证高可用的?❞「下面来跟大家分享下当时我答到的点」什么是高可用「高可用性」,指系统无间断地执行其功能的能力,代表系统的可用性程度Kafka从0.8版本开始提供了高可用机制,可保障一个或多个Broker宕机后,其他Broker能继续提供服务备份机制Kafk...

面试必问 | 聊聊Kafka的消费模型?

面试必问 | 聊聊Kafka的消费模型?

大家好,我是冰河~~最近,有些读者去头条二面,被面试官问了一个关于Kafka的问题:多个Kafka消费者如何同时消费相同Topic下的相同Partition的数据? 看似一个简单的问题,竟然把这位读者问懵了!今天,我们就一起来说说这个面试题,好了,开始今天的...

吊打面试官系列:从架构开始阐述,Kafka为什么这么快?

吊打面试官系列:从架构开始阐述,Kafka为什么这么快?

一文带你了解kafka为什么那么快?1.首先来说一下我们为什么要使用消息系统在没有使用消息系统之前,许多传统的系统业务对于消息的处理一般会采用串行方式或者并行方法;例如,你去网站注册一个账号,下面是串行跟并行的处理方式。串行方式:用户注册例子:用户主责,将注册信息记录到数据库后...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载