常见的kafka面试题

约定不等于承诺〃 2022-03-29 16:38 297阅读 0赞

1、请说明什么是Apache Kafka?

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

2、请说明什么是传统的消息传递方法?

传统的消息传递方法包括两种：

*  排队：在队列中，一组用户可以从服务器中读取消息，每条消息都发送给其中一个人。
 *  发布-订阅：在这个模型中，消息被广播给所有的用户。

3、请说明Kafka相对传统技术有什么优势?

Apache Kafka与传统的消息传递技术相比优势之处在于：

快速:单一的Kafka代理可以处理成千上万的客户端，每秒处理数兆字节的读写操作。

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

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

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

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

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

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

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

6、解释Kafka的Zookeeper是什么?我们可以在没有Zookeeper的情况下使用Kafka吗?

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

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

*  Zookeeper主要用于在集群中不同节点之间进行通信
 *  在Kafka中，它被用于提交偏移量，因此如果节点在任何情况下都失败了，它都可以从之前提交的偏移量中获取
 *  除此之外，它还执行其他活动，如: leader检测、分布式同步、配置管理、识别新节点何时离开或连接、集群、节点实时状态等等。

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

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

8、解释如何提高远程用户的吞吐量?

如果用户位于与broker不同的数据中心，则可能需要调优套接口缓冲区大小，以对长网络延迟进行摊销。

9、解释一下，在数据制作过程中，你如何能从Kafka得到准确的信息?

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

这里有两种方法，可以在数据生成时准确地获得一个语义:

*  每个分区使用一个单独的写入器，每当你发现一个网络错误，检查该分区中的最后一条消息，以查看您的最后一次写入是否成功
 *  在消息中包含一个主键(UUID或其他)，并在用户中进行反复制

10、解释如何减少ISR中的扰动?broker什么时候离开ISR?

ISR是一组与leaders完全同步的消息副本，也就是说ISR中包含了所有提交的消息。ISR应该总是包含所有的副本，直到出现真正的故障。如果一个副本从leader中脱离出来，将会从ISR中删除。

11、Kafka为什么需要复制?

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

12、如果副本在ISR中停留了很长时间表明什么?

如果一个副本在ISR中保留了很长一段时间，那么它就表明，跟踪器无法像在leader收集数据那样快速地获取数据。

13、请说明如果首选的副本不在ISR中会发生什么?

如果首选的副本不在ISR中，控制器将无法将leadership转移到首选的副本。

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

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

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

发表评论取消回复

表情：

评论列表（有 0 条评论，297人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka 面试题

文章目录 1、是什么确保了 Kafka 中服务器的负载平衡？ 2、消费者 API 的作用是什么？ 3、解释流 API 的作用？

迈不过友情╰/ 2023年10月12日 14:03/ 0 赞/ 81 阅读

相关 kafka面试题

topic 1. 为什么Topic不能减分区? Topic减分区会造成数据丢失。这是Apache Kafka自身设计所限制的。 2. 为什么限制Topic总

小咪咪/ 2023年02月28日 11:29/ 0 赞/ 24 阅读

相关 32 道常见的 Kafka 面试题

最近很多粉丝后台留言问了一些大数据的面试题，其中包括了大量的 Kafka、Spark等相关的问题，所以我特意抽出时间整理了一些大数据相关面试题，本文是 Kafka 面试相关问题

青旅半醒/ 2023年01月19日 09:54/ 0 赞/ 247 阅读

相关通关kafka之Kafka面试题

kafka kafka说说它的特性，客户端offset宕机后，同一个topic客户端能不能接上它消费？不能，只能客户端本地记录offset。 kafka 各

偏执的太偏执、/ 2023年01月14日 12:59/ 0 赞/ 171 阅读

相关 Kafka教程,Kafka面试题,Kafka详解

【订阅[专栏合集][Link 1],作者所有付费文章都能看(持续更新)】推荐【Kafka教程】[https://bigbird.blog.csdn.net/article/

桃扇骨/ 2022年12月10日 07:04/ 0 赞/ 250 阅读

相关 kafka面试题

[消息中间件面试题不错][Link 1] [RocketMQ与Kafka对比（18项差异）][RocketMQ_Kafka_18] [KAFKA：百万级吞吐量原理][KAF

太过爱你忘了你带给我的痛/ 2022年12月07日 11:40/ 0 赞/ 422 阅读

相关 kafka常见经典面试题

kafka工作原理 kafka 分为server、生产者和消费者，生产者发送消息的时候必须要指定哪个topic，消费者在消费消息的时候必须要指定哪个topic 的消息，k

深藏阁楼爱情的钟/ 2022年10月15日 09:59/ 0 赞/ 260 阅读

相关常见的kafka面试题

1、请说明什么是Apache Kafka? Apache Kafka是由Apache开发的一种发布订阅消息系统，它是一个分布式的、分区的和重复的日志服务。 2、请说明什么是

约定不等于承诺〃/ 2022年03月29日 16:38/ 0 赞/ 298 阅读

相关 kafka面试题

第一部分：kafka优势 1. 请说明什么是Apache Kafka? Apache Kafka是由Apache开发的一种发布订阅消息系统，它是一个分布式的

叁歲伎倆/ 2022年02月15日 11:09/ 0 赞/ 260 阅读

相关 Kafka面试题

谈谈Kafka Kafka机器数如何估算？ Kafka集群性能如何确定？ Kafka分区数如何设置？ Kafka副本数如何设置？ Kafka生产

左手的ㄟ右手/ 2022年01月12日 05:37/ 0 赞/ 277 阅读