linux的保存退出命令是 vim? ?esc + :X或者shift+zz

linux的退出命令是 vim? ?esc + :Q

?

Zookeeper安裝

tar -zxvf zookeeper-3.4.10.tar.gz

mv zookeeper-3.4.10/* /usr/local/zookeeper/

解壓更改conf/zoo.cfg(沒有復(fù)制一個(gè))

主要修改dataDir數(shù)據(jù)存儲(chǔ)目錄，建一個(gè)目錄/usr/local/zookeeper/data

通過命令./zkCli.sh 或者 ./zkCli.sh -server 127.0.0.1:2181

KaFka安裝

tar -zxvf kafka_2.11-1.0.0.tgz

mv kafka_2.11-1.0.0/* /usr/local/kafka/

修改server.properties中日志的位置log.dirs=/usr/local/kafka/log（需要?jiǎng)?chuàng)建目錄）

修改節(jié)點(diǎn)頂級(jí)目錄：zookeeper.connect=localhost:2181/kafka，此作用的目的就是讓修改zookeeper.properties中zookeeper的數(shù)據(jù)存儲(chǔ)地址和上面zookeeper配置數(shù)據(jù)路徑一樣

啟動(dòng)Kafka

./kafka-server-start.sh ../config/server.properties

后臺(tái)啟動(dòng)

./kafka-server-start.sh ../config/server.properties &

創(chuàng)建話題

./kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic mjxytopic1 --zookeeper localhost:2181/kafka

創(chuàng)建消費(fèi)者

./kafka-console-consumer.sh --zookeeper localhost:2181/kafka --topic mjxytopic1

創(chuàng)建生產(chǎn)者

./kafka-console-producer.sh --broker-list localhost:9092 --topic mjxytopic1

?

總結(jié)

以上是生活随笔為你收集整理的Zookeeper和kafka在linux环境下的安装的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。