14个最多见的Kafka面试题及答案【转】

 

原创 IT168企业级 2017-08-21 17:40

本文为您盘点了14个最多见的Kafka面试题,同时也是对Apache Kafka初学者必备知识点的一个整理与介绍。面试

14个最多见的Kafka面试题及答案

一、请说明什么是Apache Kafka?服务器

Apache Kafka是由Apache开发的一种发布订阅消息系统,它是一个分布式的、分区的和重复的日志服务。网络

二、请说明什么是传统的消息传递方法?分布式

传统的消息传递方法包括两种:性能

  • 排队:在队列中,一组用户能够从服务器中读取消息,每条消息都发送给其中一我的。spa

  • 发布-订阅:在这个模型中,消息被广播给全部的用户。设计

三、请说明Kafka相对传统技术有什么优点?代理

Apache Kafka与传统的消息传递技术相比优点之处在于:日志

快速:单一的Kafka代理能够处理成千上万的客户端,每秒处理数兆字节的读写操做。对象

可伸缩:在一组机器上对数据进行分区和简化,以支持更大的数据

持久:消息是持久性的,并在集群中进行复制,以防止数据丢失。

设计:它提供了容错保证和持久性

四、在Kafka中broker的意义是什么?

在Kafka集群中,broker术语用于引用服务器。

五、Kafka服务器能接收到的最大信息是多少?

Kafka服务器能够接收到的消息的最大大小是1000000字节。

六、解释Kafka的Zookeeper是什么?咱们能够在没有Zookeeper的状况下使用Kafka吗?

Zookeeper是一个开放源码的、高性能的协调服务,它用于Kafka的分布式应用。

不,不可能越过Zookeeper,直接联系Kafka broker。一旦Zookeeper中止工做,它就不能服务客户端请求。

  • Zookeeper主要用于在集群中不一样节点之间进行通讯

  • 在Kafka中,它被用于提交偏移量,所以若是节点在任何状况下都失败了,它均可以从以前提交的偏移量中获取

  • 除此以外,它还执行其余活动,如: leader检测、分布式同步、配置管理、识别新节点什么时候离开或链接、集群、节点实时状态等等。

七、解释Kafka的用户如何消费信息?

在Kafka中传递消息是经过使用sendfile API完成的。它支持将字节从套接口转移到磁盘,经过内核空间保存副本,并在内核用户之间调用内核。

八、解释如何提升远程用户的吞吐量?

若是用户位于与broker不一样的数据中心,则可能须要调优套接口缓冲区大小,以对长网络延迟进行摊销。

九、解释一下,在数据制做过程当中,你如何能从Kafka获得准确的信息?

在数据中,为了精确地得到Kafka的消息,你必须遵循两件事: 在数据消耗期间避免重复,在数据生产过程当中避免重复。

这里有两种方法,能够在数据生成时准确地得到一个语义:

  • 每一个分区使用一个单独的写入器,每当你发现一个网络错误,检查该分区中的最后一条消息,以查看您的最后一次写入是否成功

  • 在消息中包含一个主键(UUID或其余),并在用户中进行反复制

十、解释如何减小ISR中的扰动?broker何时离开ISR?

ISR是一组与leaders彻底同步的消息副本,也就是说ISR中包含了全部提交的消息。ISR应该老是包含全部的副本,直到出现真正的故障。若是一个副本从leader中脱离出来,将会从ISR中删除。

十一、Kafka为何须要复制?

Kafka的信息复制确保了任何已发布的消息不会丢失,而且能够在机器错误、程序错误或更常见些的软件升级中使用。

十二、若是副本在ISR中停留了很长时间代表什么?

若是一个副本在ISR中保留了很长一段时间,那么它就代表,跟踪器没法像在leader收集数据那样快速地获取数据。

1三、请说明若是首选的副本不在ISR中会发生什么?

若是首选的副本不在ISR中,控制器将没法将leadership转移到首选的副本。

1四、有可能在生产后发生消息偏移吗?

在大多数队列系统中,做为生产者的类没法作到这一点,它的做用是触发并忘记消息。broker将完成剩下的工做,好比使用id进行适当的元数据处理、偏移量等。

做为消息的用户,你能够从Kafka broker中得到补偿。若是你注视SimpleConsumer类,你会注意到它会获取包括偏移量做为列表的MultiFetchResponse对象。此外,当你对Kafka消息进行迭代时,你会拥有包括偏移量和消息发送的MessageAndOffset对象。

转自

14个最多见的Kafka面试题及答案http://www.toutiao.com/i6456660580726997517/

相关文章
相关标签/搜索