kafka與zookeeper的安裝和基本使用


1、zookeeper的安裝

下載后解壓,在指定的位置創建data文件夾和log文件夾,用來存儲zookeeper的信息,在data文件夾下創建一個myid的文件,里面輸入內容1

將conf里面的zoo_example.cfg修改為zoo.cfg,然后編輯里面的內容,一個是dataDir位置修改為剛才的data文件夾位置,logDataDir修改為剛才的log文件夾位置

里面的port默認為2181,可以不修改

2、kafka的安裝

下載解壓后,編輯config里面的server.properties,將zookeeper選項修改為剛才zk的配置項,logDir修改為自己創建的log文件夾,brokerid要設唯一

3、zookeeper與kafka的使用

要先啟動zookeeper,啟動命令為./zkServer.sh ../conf/zoo.cfg,查看是否啟動可以使用jps命令,有QuorumPeerMain即可

然后再啟動kafka,啟動命令為./kafka-server-start.sh ../config/server.properties (一定要 先啟動服務再創建topic,如果ip地址變化,server.properties里面的advised.host.name也要修改)

創建topic,命令為./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test (test為topic的名字)

創建生產者,命令為./kafka-console-producer.sh --broker-list localhost:9092 --topic test

重新開一個窗口創建消費者,命令為./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

然后就可以在生產者中發送消息,在消費者中接收到消息


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM