在服務(wù)器安裝的時(shí)候安裝在了/opt 的下面寒锚,opt目錄下一般用來(lái)安裝第三方軟件构资,在/usr/local中一般用來(lái)放置用戶自己的代碼
在服務(wù)端安裝zookeeper
查看進(jìn)程--方法:ps -aux | grep 'zookeeper'
系統(tǒng)有返回逼龟,說(shuō)明zookeeper啟動(dòng)臂外。
https://yq.aliyun.com/articles/662422
安裝完zookeeper后安裝kafka
yum remove wget
rpm -qa|grep wget
yum install wget
rpm -qa|grep wget
安裝kafka的時(shí)候總是顯示沒(méi)有wget命令伴澄,但是查看是有的碰缔,對(duì)于這種情況账劲,先把原來(lái)的wget刪除,然后重新安裝。
參照網(wǎng)址中的地址瀑焦,發(fā)現(xiàn)wget后面的地址無(wú)效了腌且,就進(jìn)入官網(wǎng)http://kafka.apache.org/downloads中選擇你要下載的tgz文件復(fù)制鏈接,貼到wget后面進(jìn)行下載榛瓮。
kafka的安裝后的測(cè)試參照
https://cloud.tencent.com/developer/article/1474255
當(dāng)前位置是在kafka的目錄下铺董,在同級(jí)目錄下有kafkaStart.sh,kafkaStop.sh
首先啟動(dòng)zookeeper
sh /opt/zookeeper/zookeeper-3.4.14/bin/zkServer.sh start
啟動(dòng)kafka
./kafkaStart.sh
創(chuàng)建topic 出現(xiàn)Created topid test 則創(chuàng)建成功
命令:在kafka 目錄下bin目錄下執(zhí)行:
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test test是topic名字可以隨便換哦禀晓。
查詢創(chuàng)建的top主題 出現(xiàn)test則為正常(我因?yàn)樵瓉?lái)創(chuàng)建了一個(gè)這個(gè)是test1)
下面的命令可以看自己創(chuàng)建的topic
命令:在kafka 目錄下bin目錄下執(zhí)行:
./kafka-topics.sh --list --zookeeper localhost:2181
刪除topic
命令:在kafka 目錄下bin目錄下執(zhí)行:
./kafka-topics.sh --delete --zookeeper localhost:2181 --topic test1 要?jiǎng)h除的topic名稱
測(cè)試生成者(test topic):
命令:在kafka 目錄下bin目錄下執(zhí)行:
./kafka-console-producer.sh --broker-list localhost:9092 --topic test(要啟動(dòng)生成者的topic名稱)
測(cè)試消費(fèi)者(test topic)
命令:在kafka 目錄下bin目錄下執(zhí)行:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test(要啟動(dòng)生成者的topic名稱)
生產(chǎn)者沒(méi)生產(chǎn)一個(gè)消息精续,在消費(fèi)者窗口就會(huì)添加一條。
關(guān)閉kafka粹懒,先關(guān)閉kafka再關(guān)閉zookeeper重付,如果kafka沒(méi)有關(guān)閉就關(guān)閉了zookeeper就會(huì)報(bào)錯(cuò)
./kafkaStop.sh
sh /opt/zookeeper/zookeeper-3.4.14/bin/zkServer.sh stop
我關(guān)閉以后一直報(bào)上面的錯(cuò),然后查看kafka進(jìn)程是否關(guān)閉
ps -ef|grep kafka
發(fā)現(xiàn)kafka沒(méi)有關(guān)閉凫乖,重新關(guān)閉
kill -9 12225 #12225是kafka的進(jìn)程的PID
以上就是kafka在服務(wù)器端的安裝與測(cè)試