1 kafka版本
kafka安裝需要zookeeper胀葱,但是kafka集成了zookeeper,單機(jī)部署時(shí)可以直接使用祷肯,配置kafka_2.11.X/config下的zookeeper.preperties即可
2 安裝部署
2.1解壓縮
tar -xvf kafka_2.11-2.3.0.tgz
2.2 配置zookeeper.preperties
修改dataDir和clientPort兩個(gè)配置項(xiàng)盲泛,前者是快照的存放地址,后者是客戶端連接zookeeper服務(wù)的端口
根據(jù)自己的實(shí)際情況填寫躬翁,也可以直接用默認(rèn)值
2.3 配置server.properties
修改log.dirs和zookeeper.connect兩個(gè)配置選項(xiàng)
log.dirs可以根據(jù)實(shí)際情況填寫焦蘑,也可以直接用默認(rèn)值
zookeeper.connect要和zookeeper.preperties文件中的clientPort保持一致
做完以上操作,單機(jī)版部署就完成了
3 啟動(dòng)
3.1啟動(dòng)zookeeper
nohup ./zookeeper-server-start.sh ../config/zookeeper.properties >../zookeeper.log &
后臺(tái)啟動(dòng)zookeeper盒发,啟動(dòng)日志寫入zookeeper.log
啟動(dòng)后查看zookeeper.log例嘱,看zookeeper是否啟動(dòng)成功
3.2 啟動(dòng)kafka服務(wù)
nohup ./kafka-server-start.sh ../config/server.properties > ../kafka.log&
后臺(tái)啟動(dòng)kafkaserver狡逢,啟動(dòng)日志寫入kafka.log
啟動(dòng)后查看kafka.log,看是否啟動(dòng)成功
3.2 創(chuàng)建topic
./kafka-topics.sh --create --zookeeper IP:2291 --replication-factor 1 --partitions 1 --topic test&
3.3 創(chuàng)建生產(chǎn)者
./kafka-console-producer.sh --broker-list IP:9092 --topic test&
3.4 創(chuàng)建消費(fèi)者
./kafka-console-consumer.sh --bootstrap-server IP:2291 --topic test --from-beginning
檢查生產(chǎn)者拼卵、消費(fèi)者是否正常的方法:
生產(chǎn)者和消費(fèi)者各開一個(gè)終端奢浑,分別執(zhí)行創(chuàng)建生產(chǎn)者和消費(fèi)者的命令,執(zhí)行生產(chǎn)者命令后腋腮,發(fā)送一個(gè)消息:kafkatest雀彼,消費(fèi)者終端可以收到這個(gè)消息,即為正常