一、下載kafka的安裝文件
訪問(wèn)官方地址：http://kafka.apache.org/downloads
我下載的是以下版本：
下載地址
下載地址
上傳到服務(wù)器/opt蹂窖，并解壓：
[root@iZ2ze7sn66bchxncut8rgsZ /]# cd /opt
[root@iZ2ze7sn66bchxncut8rgsZ opt]# tar -xvf kafka_2.12-2.7.0.tgz
[root@iZ2ze7sn66bchxncut8rgsZ opt]# cd kafka_2.12-2.7.0/
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# ll
總用量 56
drwxr-xr-x 3 root root 4096 12月 16 22:01 bin
drwxr-xr-x 2 root root 4096 12月 16 22:01 config
drwxr-xr-x 2 root root 8192 2月 1 14:44 libs
-rw-r--r-- 1 root root 29975 12月 16 21:58 LICENSE
-rw-r--r-- 1 root root 337 12月 16 21:58 NOTICE
drwxr-xr-x 2 root root 44 12月 16 22:01 site-docs
二、啟動(dòng)服務(wù)
這里有兩種方式配置ZK：
1）自己搭建單獨(dú)的一套服務(wù)
2）使用kafka提供的單節(jié)點(diǎn)zk服務(wù)抡锈。
這里為了演示且zk不是關(guān)注點(diǎn)疾忍，我們直接使用自帶的zk。
[root@iZ2ze7sn66bchxncut8rgsZ bin]# cd ../
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# ./bin/zookeeper-server-start.sh config/zookeeper.properties
啟動(dòng)kafka服務(wù)：
./bin/kafka-server-start.sh config/server.properties
以上啟動(dòng)都是直接啟動(dòng)的床三，真實(shí)請(qǐng)使用后臺(tái)啟動(dòng)nohup：
#啟動(dòng)zk
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >/dev/null &
#啟動(dòng)kafka服務(wù)
nohup ./bin/kafka-server-start.sh config/server.properties >/dev/null &
三一罩、驗(yàn)證
有一款插件，朋友們可以下載下撇簿，利于我們分下線上的問(wèn)題聂渊。
下載地址如下：https://www.kafkatool.com/
kafka tool
打開(kāi)新窗口，驗(yàn)證kafka服務(wù)是否成功：
1四瘫、創(chuàng)建一個(gè)topic汉嗽，名為“test-kafka”，它有一個(gè)分區(qū)和一個(gè)副本：
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-kafka
Created topic test-kafka.
2找蜜、查看當(dāng)前存在的topic
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
test
test-kafka
3饼暑、創(chuàng)建生產(chǎn)者
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-kafka
>
4、打開(kāi)新窗口洗做，創(chuàng)建消費(fèi)者
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-kafka --from-beginning
5弓叛、發(fā)送消息，查看結(jié)果
使用生產(chǎn)者發(fā)送消息“hello world”：
image.png
查看消費(fèi)者：
消費(fèi)者
從上面看到消費(fèi)者成功接收到生產(chǎn)者發(fā)送的消息了诚纸。
下一章節(jié)撰筷，我們看下如何部署kafka集群。
