下載地址:http://kafka.apache.org/downloads 我裝的是0.10.2.1寿冕,tar? zxvf解壓指令
1捺癞、先啟動zookeeper,可選擇kafka自帶的皮仁,也可用獨(dú)立的zookeeper
nohup bash zookeeper-server-start.sh ../config/zookeeper.properties &
2掀序、準(zhǔn)備kafka服務(wù)端配置文件
在conf下copy出三份配置文件server.properties璧疗,修改其中的broker.id(機(jī)器號)肴甸、listeners(監(jiān)聽的ip和端口)相嵌、log.dir(消息日志目錄)信息區(qū)分出來“三臺”服務(wù)器。多加了default.replication.factor = 3承桥,表示建立的partition默認(rèn)有三個replica(副本)驻粟;delete.topic.enable=true,支持topic刪除功能快毛,默認(rèn)配置是false格嗅。其余使用提供的默認(rèn)的配置番挺。分別啟動 ? ? ? ? ?
服務(wù)端參數(shù)含義可參考http://orchome.com/12唠帝,另外服務(wù)端提供的消費(fèi)者和生產(chǎn)者配置⌒兀可選擇不配置襟衰,在客戶端代碼里配置。
默認(rèn)內(nèi)存是1G粪摘,kafka-server-start.sh可修改
kafka提供了很方便的命令行工具
kafka-topics.sh topic的增加刪除查的操作
./kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic "kafka10-topic-20170922" --partitions 3 --replication-factor 3
創(chuàng)建一個topic瀑晒,3個分區(qū),3個副本徘意,名字kafka10-topic-20170922
kafka-configs.sh 對topic broker client配置修改的工具
todo 其他一些腳本工具使用