離線安裝zookeeper和kafka

1.安裝ZooKeeper 3.6.1
官網下載最新版的zookeeper

https://zookeeper.apache.org/...

• 給/opt目錄賦予當前用戶的權限

sudo chown -R ${USER}:${USER} /opt

• 將下載好的zooKeeper安裝包copy到/opt下面並解壓

cp ~/Downloads/apache-zookeeper-3.6.1-bin.tar.gz /opt
tar xvf apache-zookeeper-3.6.1-bin.tar.gz

• 將zookeeper目錄下的conf裏的zoo_sample.cfg拷貝命名爲zoo.cfg

cd /opt/apache-zookeeper-3.6.1-bin/conf
cp zoo_sample.cfg zoo.cfg

• 修改系統環境變量~/.zshrc

vim ~/.zshrc
export zk=/opt/apache-zookeeper-3.6.1-bin
export PATH=$PATH:$zk/bin

• 啓動zookeeper

zkServer.sh start
menglong@menglong conf % zkServer.sh start
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: /opt/apache-zookeeper-3.6.1-bin/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

• jps查看zookeeper是否啓動

jps
menglong@menglong conf % jps
1410 QuorumPeerMain
1432 Jps

2.安裝kafka2.5.0
官網下載最新版的kafka
http://kafka.apache.org/downl...

• 將下載好的zooKeeper安裝包copy到/opt下面並解壓

cp ~/Downloads/kafka_2.12-2.5.0.tgz /opt
tar xvf kafka_2.12-2.5.0.tgz

• 修改server.properties

cd /opt/kafka_2.12-2.5.0/config
vim server.properties
查找到#advertised.listeners=PLAINTEXT://your.host.name:9092

修改成advertised.listeners=PLAINTEXT://localhost:9092

• 修改系統環境變量~/.zshrc

vim ~/.zshrc
export zk=/opt/apache-zookeeper-3.6.1-bin
export kafka=/opt/kafka_2.12-2.5.0
export PATH=$PATH:$zk/bin:$kafka/bin

• 啓動kafka

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

• 查看kafka啓動

jps
menglong@menglong kafka_2.12-2.5.0 % jps
1410 QuorumPeerMain
2052 Jps
1733 Kafka

3.建立topic test

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 5 --topic test

4.使用test topic生產數據

menglong@menglong kafka_2.12-2.5.0 % kafka-console-producer.sh --broker-list localhost:9092 --topic test
>this is my first message

5.使用test topic消費數據

menglong@menglong kafka_2.12-2.5.0 % jps
4689 Kafka
1410 QuorumPeerMain
6297 ConsoleProducer
6623 Jps
menglong@menglong kafka_2.12-2.5.0 % kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test this is my first message