#kafka數據的存放地址，多個地址的話用逗號分

log.dirs=/tmp/kafka-logs

?

#broker server服務端口

port=9092

?

#這個參數會在日志segment沒有達到log.segment.bytes設置的大小，也會強制新建一個segment會被?topic創建時的指定參數覆蓋

log.roll.hours=24

?

#是否允許控制器關閉broker ,若是設置為true,會關閉所有在這個broker上的leader，并轉移到其他broker

controlled.shutdown.enable=false

?

#控制器關閉的嘗試次數

controlled.shutdown.max.retries=3

?

#每次關閉嘗試的時間間隔
controlled.shutdown.retry.backoff.ms=5000

?

#partition?leader與replicas數據同步時,消息的隊列

controller.message.queue.size=10

?

#partition?leader與replicas之間通訊時,socket的超時時間

controller.socket.timeout.ms=30000

?

#是否允許自動創建topic，若是false，就需要通過命令創建topic

default.replication.factory=1

?

#表示消息體的最大大小，單位是字節

message.max.bytes=1000000

?

#broker處理磁盤IO的線程數，數值應該大于你的硬盤數

num.io.threads=8

?

#broker處理消息的最大線程數，一般情況下不需要去修改

num.network.threads=3

?

#每個topic的分區個數，若是在topic創建時候沒有指定的話會被topic創建時的指定參數覆蓋

num.partitions=1

?

#leader中進行復制的線程數，增大這個數值會增加relipca的IO

num.replica.fetchers=1

?

#ZooKeeper的連接超時時間

zookeeper.connection.timeout.ms=20000

?

?

?

其他參考：

轉載于:https://www.cnblogs.com/yangsy0915/p/5933332.html

總結

以上是生活随笔為你收集整理的Kafka集群配置说明的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。