1. 程式人生 > 其它 >centos安裝ZooKeeper和kafka

centos安裝ZooKeeper和kafka

A Zookeeper安裝與配置
一:下載zookeeper安裝包
從官網下載:http://mirrors.hust.edu.cn/apache/zookeeper/
二:上傳並配置zookeeper
1.放在/usr/local目錄下並解壓。
tar -zxvf zookeeper-3.4.13.tar.gz
即zookeeper路徑為:/usr/local/zookeeper-3.4.13/zookeeper-3.4.13
2.進入/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/conf目錄下
將zoo_sample.cfg複製一份取名為zoo.cfg
cp zoo_sample.cfg zoo.cfg
編輯zoo.cfg檔案
vi zoo.cfg
內容為:
dataDir=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/data
clientPort=2181
注:如果沒有data檔案請建立一個。
3.啟動zookeeper
進入zookeeper的bin目錄下
cd /usr/local/zookeeper-3.4.13/zookeeper-3.4.13/bin
啟動zookeeper
./zkServer.sh start
注:如果提示許可權不夠,可以修改此檔案許可權即:
chmod 777 ./zkServer.sh
再次執行
./zkServer.sh start
4.檢視zookeeper啟動狀態
./zkServer.sh status
5.將zookeeper修改為開機啟動
(1)進入到/etc/rc.d/init.d目錄下
cd /etc/rc.d/init.d
(2)建立一個zookeeper的檔案,並編輯
touch zookeeper
vi zookeeper
內容:
#!/bin/bash
#chkconfig: 2345 10 90
#description: service zookeeper
export JAVA_HOME=/usr/local/java/jdk1.8.0_191
export ZOO_LOG_DIR=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13/logs
ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.13/zookeeper-3.4.13
su root ${ZOOKEEPER_HOME}/bin/zkServer.sh "$1"
然後儲存退出。
(3)給zookeeper檔案新增可執行許可權
chmod +x /etc/rc.d/init.d/zookeeper
(4)把zookeeper這個指令碼新增到開機啟動項裡面
chkconfig --add zookeeper
(5)重啟linux
reboot
(6)檢視zookeeper是否啟動
service zookeeper status
B kafka安裝與配置
一:從官網下載安裝包
下載地址: http://archive.apache.org/dist/kafka/0.8.1.1/kafka_2.10-0.8.1.1.tgz
二:安裝和配置kafka
1.解壓kafka壓縮包並放到/usr/local下
tar -xzf kafka_2.10-0.8.1.1.tar.gz
路徑為:/usr/local/kafka_2.10-0.8.1.1
2.配置server.properties檔案
cd /usr/local/kafka_2.10-0.8.1.1/config
vim server.properties
修改屬性為:zookeeper.connect=localhost:2181
3.啟動kafka
cd /usr/local/kafka_2.10-0.8.1.1/bin
./kafka-server-start.sh -daemon ../config/server.properties
4.建立topic
cd /usr/local/kafka_2.10-0.8.1.1/bin
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
5.驗證topic是否建立成功
cd /usr/local/kafka_2.10-0.8.1.1/bin
./kafka-topics.sh --list --zookeeper localhost:2181
6.檢視topic描述
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
7.傳送訊息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
8.接收訊息
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
3A網路科技致力於提供最穩定最快速的雲伺服器建設,通過高速的cn2線路顯著提升網路速度,搭配企業級硬體裝置竭誠為客戶提供高效且可靠的伺服器應用方案,加上十幾年專業團隊的協作來保障伺服器的高質量以及超高安全性。