1、準(zhǔn)備好kafka安裝包盖呼，unzip xxx.zip 解壓栖秕。
壓縮包網(wǎng)盤地址：http://pan.baidu.com/s/1o8pmH2U
2蜂桶、進(jìn)入到kafka的config目錄
3寝姿、先搭建三個(gè)節(jié)點(diǎn)zk集群交排，三臺(tái)機(jī)器。
修改zookeeper.properties如下配置信息饵筑。
cd /home/xxx/data/zookeeper 目錄
每臺(tái)機(jī)器都需要?jiǎng)?chuàng)建myid文件埃篓，內(nèi)容依次為1，2根资，3
如下是3臺(tái)集群服務(wù)器樣例：
4架专、三臺(tái)機(jī)器都修改好zookeeper.properties文件和創(chuàng)建好myid文件
進(jìn)入kafka目錄
執(zhí)行啟動(dòng)zookeeper命令：nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >logs/zookeeper.log 2>1 &
三臺(tái)機(jī)器都執(zhí)行啟動(dòng)命令，查看logs/zookeeper.log 文件玄帕，沒有報(bào)錯(cuò)就說明zookeeper集群?jiǎn)?dòng)成功了部脚。
5、著手搭建kafka集群
修改server.properties配置文件裤纹，三個(gè)配置相應(yīng)修改委刘。
host.name 為各機(jī)器的IP地址
配置文件最下方：
5、啟動(dòng)kafka三個(gè)節(jié)點(diǎn)
進(jìn)入kafka目錄服傍，執(zhí)行如下命令
nohup ./bin/kafka-server-start.sh config/server.properties >logs/kafka.log 2>1 &
6钱雷、測(cè)試kafka集群
1-進(jìn)入kafka根目錄骂铁，創(chuàng)建topic--test
bin/kafka-topics.sh --create --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --replication-factor 1 --partitions 1 --topic test
2-列出已創(chuàng)建的topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
3-模擬客戶端去發(fā)送消息
bin/kafka-console-producer.sh --broker-list 192.168.1.xx:9092,192.168.1.xx:9092,192.168.1.xx:9092 --topic test
4-模擬客戶端去接受消息
bin/kafka-console-consumer.sh --zookeeper 192.168.1.xx:2181,192.168.1.xx:2181,192.168.1.xx:2181 --from-beginning --topic test
7吹零、自己測(cè)試結(jié)果
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic test
