kafka常見面試問題(1)

2021-10-11 12:01:54 字數 1607 閱讀 2996

問題1:什麼是apache kafka?

答:apache kafka是乙個發布 - 訂閱開源訊息**應用程式。這個訊息傳遞應用程式是用「scala」編碼的。基本上,這個專案是由apache軟體啟動的。kafka的設計模式主要基於事務日誌設計。
問題2:kafka中有哪幾個元件?

答:kafka最重要的元素是:

主題:kafka主題是一堆或一組訊息。生產者:在kafka,生產者發布通訊以及向kafka主題發布訊息。消費者:kafka消費者訂閱了乙個主題,並且還從主題中讀取和處理訊息。經紀人:在管理主題中的訊息儲存時,我們使用kafka brokers。
問題3:解釋偏移的作用。

答:給分割槽中的訊息提供了乙個順序id號,我們稱之為偏移量。因此,為了唯一地識別分割槽中的每條訊息,我們使用這些偏移量。
問題4:什麼是消費者組?

答:消費者組的概念是apache kafka獨有的。基本上,每個kafka消費群體都由乙個或多個共同消費一組訂閱主題的消費者組成。
問題5:zookeeper在kafka中的作用是什麼?

答:apache kafka是乙個使用zookeeper構建的分布式系統。雖然,zookeeper的主要作用是在集群中的不同節點之間建立協調。但是,如果任何節點失敗,我們還使用zookeeper從先前提交的偏移量中恢復,因為它做週期性提交偏移量工作。
問題6:沒有zookeeper可以使用kafka嗎?

答:繞過zookeeper並直接連線到kafka伺服器是不可能的,所以答案是否定的。如果以某種方式,使zookeeper關閉,則無法為任何客戶端請求提供服務。
問題8:為什麼kafka技術很重要?

答:kafka有一些優點,因此使用起來很重要:

高吞吐量:我們在kafka中不需要任何大型硬體,因為它能夠處理高速和大容量資料。此外,它還可以支援每秒數千條訊息的訊息吞吐量。低延遲:kafka可以輕鬆處理這些訊息,具有毫秒級的極低延遲,這是大多數新用例所要求的。容錯:kafka能夠抵抗集群中的節點/機器故障。耐久性:由於kafka支援訊息複製,因此訊息永遠不會丟失。這是耐久性背後的原因之一。可擴充套件性:卡夫卡可以擴充套件,而不需要通過新增額外的節點而在執行中造成任何停機。
問題9:kafka的主要api有哪些?

答:apache kafka有4個主要api:

生產者api 消費者api 流 api 聯結器api
問題10:什麼是消費者或使用者?

答:kafka消費者訂閱乙個主題,並讀取和處理來自該主題的訊息。此外,有了消費者組的名字,消費者就給自己貼上了標籤。換句話說,在每個訂閱使用者組中,發布到主題的每個記錄都傳遞到乙個使用者例項。確保使用者例項可能位於單獨的程序或單獨的計算機上。

SVM常見面試問題

答 幾何間隔與樣本的誤分次數間存在關係 其中的分母就是樣本到分類間隔距離,分子中的r是所有樣本中的最長向量值 答 會,超平面會靠近樣本少的類別。因為使用的是軟間隔分類,而如果對所有類別都是使用同樣的懲罰係數,則由於優化目標裡面有最小化懲罰量,所以靠近少數樣本時,其懲罰量會少一些。比如 假設理想的分隔...

C 常見面試問題

一 抽象與介面的區別 1,抽象 abstract 1 抽象類中可以有抽象方法,也可沒有 2 抽象方法包含實現,也可以由子類實現 3 抽象類不能被sealed修飾,只能使用abstract關鍵字 4 抽象方法不能在抽象類外部宣告 5 抽象類只能單繼承 6 可以有虛方法 virtual 在不同的繼承中,...

SpringMVC 常見面試問題

springmvc流程 原理 流程圖 亂碼問題 重定向和 在返回值前面加 redirect 或 forward return forward 跳轉的頁面或路由 重定向和 的區別 全域性異常 自定義實現spring的全域性異常解析器handlerexceptionresolver springboot...