Broker 概述
========
-
Broker 的启动
-
Broker 内部的模块组成
Broker 的基本模块
===========
-
?SocketServer
-
?KafkaRequestHandlerPool
-
3KafkaApis
-
?KafkaHealthcheck
Broker 的控制管理模块
=============
-
?KafkaController 的选举策略
-
?KafkaController 的初始化
-
?Topic 的分区状态转换机制
-
Topic 分区的领导者副本选举策略
-
Topic 分区的副本状态转换机制
-
?KafkaController 内部的
-
?Kafka 集群的负载均衡流程
-
?Kafka 集群的 Topi 删除流程
-
KafkaController 的通信模块
Topic 的管理工具
==========
生产者
===
消费者
===
Kafka 的典型应用
==========
-
?Kafka 和 Storm 的集成
-
Kafka 和 ELK 的集成
-
Kafka 和 Hadoop 的集成
-
?Kafka 和 Spark 的集成
Kafka 的综合实例
==========
-
安防大数据的主要应用
-
?Kafka 在安防整体解决方案中的角色
-
?典型业务
下面是我整理出的一些 kafka 面试题，不妨先看看问题，自己先尝试回答一下，再看答案。看看自己掌握得如何了，在这里我只会展示问题，至于答案已经和华为架构师的这份《Kafka 源码解析与实战》一起整理成 PDF 文档
Kafka 基础篇
-
1.Kafka 的用途有哪些?使用场景如何?
-
2.Kafka 中的 ISR、AR 又代表什么? ISR 的伸缩又指什么
-
3.Kafka 中的 HW、LEO. LSO. LW 等分别代表什么?
-
4.Kafka 中是怎么体现消息顺序性的?
-
5.Kafka 中的分区器、序列化器、是否了解？它们之间的处理顺序是什么？
-
6.Kafka 生产者客户端的整体结构是什么样子的?
-
7.Kafka 生产者客户端中使用了几个线程来处理?分别是什么?
-
8.Kafka 的旧版 Scala 的消费者客户端的设计有什么缺陷?
-
9.“消费者中的消费者个数如果超过 topic 的分区，那么就会有消费者消费不到数据”这句话是否正确？如果正确，那么有没有什么 hack 的手段？
-
10.有哪些情形会造成重复消费?
-
12.KafkaConsumer 是非线程安全的，那么怎么样实现多线程消费?
-
14.当你使用 kafka-topics.sh 创建（删除）了一个 topic 之后，Kafka 背后会执行什么逻辑？
-
15.topic 的分区数可不可以增加？如果可以怎么增加？如果不可以，那又是为什么？
-
16.topic 的分区数可不可以减少？如果可以怎么减少？如果不可以，那又是为什么？
-
17.创建 topic 时如何选择合适的分区数?
小伙伴们有兴趣想了解更多相关学习资料请点赞收藏+评论转发+关注我之后私信我，注意回复【000】即可获取更多免费资料！
