1.Kafka中的ISR、AR又代表什么？

ISR：與leader保持同步的follower集合

AR：分區(qū)的所有副本

2.Kafka中的HW、LEO等分別代表什么？

LEO：沒個副本的最后條消息的offset

HW：一個分區(qū)中所有副本最小的offset

3.Kafka中是怎么體現(xiàn)消息順序性的？

每個分區(qū)內(nèi)，每條消息都有一個offset，故只能保證分區(qū)內(nèi)有序。

4.Kafka中的分區(qū)器、序列化器、攔截器是否了解？它們之間的處理順序是什么？

攔截器 -> 序列化器 -> 分區(qū)器

5.Kafka生產(chǎn)者客戶端的整體結(jié)構(gòu)是什么樣子的？使用了幾個線程來處理？分別是什么？

6.“消費(fèi)組中的消費(fèi)者個數(shù)如果超過topic的分區(qū)，那么就會有消費(fèi)者消費(fèi)不到數(shù)據(jù)”這句話是否正確？

正確

7.消費(fèi)者提交消費(fèi)位移時提交的是當(dāng)前消費(fèi)到的最新消息的offset還是offset+1？

offset+1

8.有哪些情形會造成重復(fù)消費(fèi)？

9.那些情景會造成消息漏消費(fèi)？

先提交offset，后消費(fèi)，有可能造成數(shù)據(jù)的重復(fù)

10.當(dāng)你使用kafka-topics.sh創(chuàng)建（刪除）了一個topic之后，Kafka背后會執(zhí)行什么邏輯？

1）會在zookeeper中的/brokers/topics節(jié)點(diǎn)下創(chuàng)建一個新的topic節(jié)點(diǎn)，如：/brokers/topics/first

2）觸發(fā)Controller的監(jiān)聽程序

3）kafka Controller 負(fù)責(zé)topic的創(chuàng)建工作，并更新metadata cache

11.topic的分區(qū)數(shù)可不可以增加？如果可以怎么增加？如果不可以，那又是為什么？

可以增加

bin/kafka-topics.sh --zookeeper localhost:2181/kafka --alter --topic topic-config --partitions 3

12.topic的分區(qū)數(shù)可不可以減少？如果可以怎么減少？如果不可以，那又是為什么？

不可以減少，被刪除的分區(qū)數(shù)據(jù)難以處理。

13.Kafka有內(nèi)部的topic嗎？如果有是什么？有什么所用？

__consumer_offsets,保存消費(fèi)者offset

14.Kafka分區(qū)分配的概念？

一個topic多個分區(qū)，一個消費(fèi)者組多個消費(fèi)者，故需要將分區(qū)分配個消費(fèi)者(roundrobin、range)

15.簡述Kafka的日志目錄結(jié)構(gòu)？

每個分區(qū)對應(yīng)一個文件夾，文件夾的命名為topic-0，topic-1，內(nèi)部為.log和.index文件

16.如果我指定了一個offset，Kafka Controller怎么查找到對應(yīng)的消息？

17.聊一聊Kafka Controller的作用？

負(fù)責(zé)管理集群broker的上下線，所有topic的分區(qū)副本分配和leader選舉等工作。

18.Kafka中有那些地方需要選舉？這些地方的選舉策略又有哪些？

partition leader（ISR），controller（先到先得）

19.失效副本是指什么？有那些應(yīng)對措施？

不能及時與leader同步，暫時踢出ISR，等其追上leader之后再重新加入

20.Kafka的那些設(shè)計(jì)讓它有如此高的性能？

分區(qū)，順序?qū)懘疟P，0-copy

總結(jié)

以上是生活随笔為你收集整理的kafka 创建topic_Kafka试题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。