#kafka數(shù)據(jù)的存放地址，多個(gè)地址的話用逗號(hào)分

log.dirs=/tmp/kafka-logs

?

#broker server服務(wù)端口

port=9092

?

#這個(gè)參數(shù)會(huì)在日志segment沒(méi)有達(dá)到log.segment.bytes設(shè)置的大小，也會(huì)強(qiáng)制新建一個(gè)segment會(huì)被?topic創(chuàng)建時(shí)的指定參數(shù)覆蓋

log.roll.hours=24

?

#是否允許控制器關(guān)閉broker ,若是設(shè)置為true,會(huì)關(guān)閉所有在這個(gè)broker上的leader，并轉(zhuǎn)移到其他broker

controlled.shutdown.enable=false

?

#控制器關(guān)閉的嘗試次數(shù)

controlled.shutdown.max.retries=3

?

#每次關(guān)閉嘗試的時(shí)間間隔
controlled.shutdown.retry.backoff.ms=5000

?

#partition?leader與replicas數(shù)據(jù)同步時(shí),消息的隊(duì)列

controller.message.queue.size=10

?

#partition?leader與replicas之間通訊時(shí),socket的超時(shí)時(shí)間

controller.socket.timeout.ms=30000

?

#是否允許自動(dòng)創(chuàng)建topic，若是false，就需要通過(guò)命令創(chuàng)建topic

default.replication.factory=1

?

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

message.max.bytes=1000000

?

#broker處理磁盤(pán)IO的線程數(shù)，數(shù)值應(yīng)該大于你的硬盤(pán)數(shù)

num.io.threads=8

?

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

num.network.threads=3

?

#每個(gè)topic的分區(qū)個(gè)數(shù)，若是在topic創(chuàng)建時(shí)候沒(méi)有指定的話會(huì)被topic創(chuàng)建時(shí)的指定參數(shù)覆蓋

num.partitions=1

?

#leader中進(jìn)行復(fù)制的線程數(shù)，增大這個(gè)數(shù)值會(huì)增加relipca的IO

num.replica.fetchers=1

?

#ZooKeeper的連接超時(shí)時(shí)間

zookeeper.connection.timeout.ms=20000

?

?

?

其他參考：

轉(zhuǎn)載于:https://www.cnblogs.com/yangsy0915/p/5933332.html

總結(jié)

以上是生活随笔為你收集整理的Kafka集群配置说明的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。