1. 程式人生 > >kafka單機模式部署安裝,zookeeper啟動

kafka單機模式部署安裝,zookeeper啟動

模式 下載 CA jpg str 啟動 ear localhost strong

在root的用戶下

1):前提 安裝JDK環境,設置JAVA環境變量

2):下載kafka,命令:wget http://mirrors.shuosc.org/apache/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz

3):下載zookeeper,命令:wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

4):然後去解壓zookeeper包,我把zookeeper-3.4.10文件夾名稱改為了zookeeper ,首先找到conf的文件夾,然後備份一份zoo_sample.cfg文件 ,備份名為zoo.cfg

命令:cp zoo_sample.cfg zoo.cfg

5):打開zoo.cfg的文件

命 令 :vim zoo.cfg

dataDir=/tmp/zookeeper (雖然給出這個路徑給你,但是系統並沒有,要你自己創建的,你可以不按這個路徑)
dataLogDir=/tmp/zookeeperlog (這是我另外夾的用來存放日誌文件)

6):啟動 zookeeper

root@debian8:/usr/local/zookeeper# 命令 : bin/zkServer.sh start

技術分享圖片

7)解壓kafka的包,我把kafka_2.10-0.10.2.1文件夾名稱改為了kafka,到config路徑下找到 server.properties

找到log.dirs=/tmp/kafka-logs (跟剛剛zookeper一樣創建)

listeners(所在機器ip地址)我這裏是本地,不管它

8):啟動kafka

命令:nohup bin/kafka-server-start.sh config/server.properties &

運行之後不管成功否它都會在你的kafka包下生成一個 nohup.out的文件

9): 查看是否成功了

新建一個topic
命令:bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看 topic是否成功
命令:bin/kafka-topics.sh --list --zookeeper localhost:2181

10):把kafka的生產者啟動來

命令 :bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

11):另開一個終端(創建新的),把消費者啟動起來:

命令:bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test —from-beginning

12):在生產者終端輸入數據,消費者馬上就會消費顯示出來

生產者:

技術分享圖片

消費者:

技術分享圖片

kafka單機模式部署安裝,zookeeper啟動