KAFKA詳解 主題說明（二）

從生產者的角度來說，他所操作的單元，一般情況下屬於主題為單位

從消費者的角度來說，他所操作的單元，一般情況下屬於主題為單位

生產者、消費者可以以主題更細單位來操作--->(分割槽)，也是訊息的分類

從kafka的角度來說，沒有限制生產者也沒有限制消費者

生產者與消費者在處理資料的時候，必須要知道要操作的主題是哪乙個

1、乙個broker服務下，是否可以建立多個分割槽？

可以，broker數與分割槽數沒有關係

2、乙個broker服務下，是否可以建立多個副本因子

不可以。但報錯

replication factor: 3 larger than **ailable brokers:

建立主題時，副本因子應該小於等於可用的broker數
kafka-topics.sh --create --topic mytopic5 --zookeeper localhost:2181 --partitions 3 --replication-factor 1 --config max.message.bytes=6400 --config flush.messages=1

kafka-topics.sh --describe --zookeeper localhost:2181

在kafka中每乙個分割槽會有乙個編號：從0開始

kafka shell ：運維常用命令

Kafka刪除主題詳解

在kafka的使用 測試過程中，可能老是會遇到想要刪除某個主題的需求，但是由於對其內部機制不夠了解，總是無法有效的刪除主題。今天這篇文章詳細討論如何徹底的刪除乙個主題。在kafka的broker端的配置引數中有這樣乙個引數 delete.topic.enable，必須將它設定為true才能夠刪除ka...

Kafka 位移主題詳解

建立時機 提交策略 刪除過期訊息優點 缺點kafka中的內部位移主題是 consumer offsets。offset訊息 簡單的可以理解為 key value 註冊訊息 用來註冊 儲存 consumer group資訊的訊息 墓碑訊息 作用用於刪除 group 過期位移甚至是刪除 group 的訊...

kafka自動建立主題

kafka集群環境搭建完成後，整合到專案開發中，我需要給某個topic傳送訊息，以及監聽消費該topic中的訊息，難道我需要事先用kafka命令先去伺服器建立乙個topic，然後再供專案使用嗎？有沒有我在專案配置檔案裡指定kafka的topic 然後啟動服務的時候，kafka就可以自動幫我建立好呢？...