應用kafka的經驗

2022-10-10 12:06:08 字數 708 閱讀 9349

kafka 部署注意事項?啟動使用者,非root

安裝目錄許可權:除了資料目錄和日誌目錄是讀寫外,bin目錄是可執行,其他目錄應該唯讀

預設埠修改

只容許內網訪問

整合監控和管理軟體

開啟認證

kafka 如何保證訊息不丟失?

訊息可靠傳送

producer要注意配置ack的級別

acks=0 生產者只管發,不管伺服器是什麼響應

acks=1 只要集群首領節點收到訊息,就認為成功

acks=all 所有follow都收到,才認為成功

可靠消費

consumer要注意offset如何提交。因為consumer一次拉取一批訊息,如果在處理這一批訊息**錯,offset提交方式不當會丟訊息或重複消費。

要可靠消費,可以提交特定偏移量的map。

堆積時,如何而提高消費能力

consumer必須指定consumergroup id,否則沒法增加消費者。

可能需要先增加topic的partition數量,再增加消費者的數量。

消費者數量不能大於topic的partition數量,否則有消費者收不到訊息。

kafka 如何監控?

借助程序監控,zookeeper資訊監控,監控生產者,消費者等。有開源元件

kafka 怎麼判斷乙個group 的消費者掛掉了

長時間offset偏移量不變,可以預警

Kafka專案經驗

1.kafka 壓測 用 kafka 官方自帶的指令碼,對 kafka 進行壓測。kafka 壓測時,可以檢視到哪個地方出 現了瓶頸 cpu,記憶體,網路 io 一般都是網路 io 達到瓶頸。kafka consumer perf test.sh kafka producer perf test.s...

Kafka的應用場景

1 建立實時的資料管道,以可靠地在系統或應用程式之間獲取資料 2 構建實時流應用程式,以轉換或響應資料流 如圖,可以看到 1 producers 可以有很多的應用程式,將訊息資料放到kafka的集群中。2 consumers 可以有很多的應用程式,將訊息資料從kafka集群中拉取出來。3 conne...

Kafka 關於壓縮的一點經驗

就壓縮而言,對於資料儲存應該是乙個比較大的優化,而 kafka 自然也是支援這種特性的,但是這裡可能會有那麼一點坑。我們主要從 何時產生壓縮?何時會解壓縮?兩個方面來說,並針對一些可能出現的坑做一些說明。生產者為了資料在傳輸到 kafka 可以更快,那麼在生產者啟動壓縮自然是很正常的。broker端...