準(zhǔn)備工作:準(zhǔn)備三臺(tái)虛擬機(jī)梧却,分別下載kafka缘挑,跟zookeeper(注意zookeeper版本選擇最好跟kafka對應(yīng)氮惯,可以去kafka/lib/查看自帶的zk的版本沟突,然后去下載對應(yīng)的版本號(hào))花颗,我的版本分別使用的是kafka_2.10-0.10.2.1,zookeeper-3.4.9惠拭。
- 先部署zk
-
解壓zk扩劝,并創(chuàng)建一個(gè)文件夾存放數(shù)據(jù)。
-
修改/zookeeper-3.4.9/conf下的zoo.cfg文件
-
修改一下日志輸出的位置职辅,修改zookeeper-3.4.9/bin/zkEnv.sh棒呛,以及zookeeper-3.4.9/conf下的log4j.properties
- 在你開始創(chuàng)建的文件夾里面創(chuàng)建myid文件并寫入你的zk的id數(shù)值
-
啟動(dòng)zk
- 其他機(jī)器是同樣的步驟進(jìn)行配置
- 部署kafka
-
解壓kafka,并創(chuàng)建一個(gè)存放數(shù)據(jù)的文件夾
2.修改kafka/config/server.properties
3.啟動(dòng)kafka
4.其他機(jī)器也是同樣的步驟
分布式部署kafka完畢域携,可以進(jìn)行produce跟consume了