配置檔案在config/server.properties
下面的一些配置可能是你需要進行修改的。
broker.id
整數，建議根據ip區分
log.dirs
kafka存放訊息檔案的路徑，
預設/tmp/kafka-logs
port
broker用於接收producer訊息的埠
zookeeper.connnect
zookeeper連線
格式為 ip1:port,ip2:port,ip3:port
message.max.bytes
單條訊息的最大長度
num.network.threads
broker用於處理網路請求的執行緒數
如不配置預設為3，server.properties預設是2
num.io.threads
broker用於執行網路請求的io執行緒數
如不配置預設為8，server.properties預設是2可適當增大，
queued.max.requests
排隊等候io執行緒執行的requests
預設為500
host.name
broker的hostname
預設null,建議寫主機的ip,不然消費端不配置hosts會有麻煩
num.partitions
topic的預設分割槽數
預設1log.retention.hours
訊息被刪除前儲存多少小時
預設1周168小時
auto.create.topics.enable
是否可以程式自動建立topic
預設true,建議false
default.replication.factor
訊息備份數目
預設1不做複製，建議修改
num.replica.fetchers
用於複製leader訊息到follower的io執行緒數
預設1
kafka乙份配置 說明
配置參考 官方說明 broker.id可以自動獲取，但避免擴容 下線導致部分id出現重複，因此手工指定 broker.id broker id 是否通過管理工具刪除topic delete.topic.enable true 能否自動建立topic，這裡修改為false auto.create.to...
kafka乙份配置 說明
配置參考 官方說明 broker.id可以自動獲取，但避免擴容 下線導致部分id出現重複，因此手工指定 broker.id broker id 是否通過管理工具刪除topic delete.topic.enable true 能否自動建立topic，這裡修改為false auto.create.to...
簡單說明kafka
什麼是kafka kafka是用於構建實時資料管道和流應用程式。具有橫向擴充套件，容錯，wicked fast 快 等優點 簡單說明什麼是kafka apache kafka是訊息中介軟體的一種，我發現很多人不知道訊息中介軟體是什麼，在開始學習之前，我這邊就先簡單的解釋一下什麼是訊息中介軟體，只是粗...