1. 到官網下載tgz檔案：https://kafka.apache.org/downloads

2. 建立存放kafka的資料夾：sudo mkdir /opt/module

3. 解壓下載的檔案：

sudo tar -xvf kafka_2.12-2.8.0.tgz -C /opt/module
cd /opt/module
mv kafka_2.12-2.8.0 kafka
cd kafka

4.使用預設配置啟動zookeeper, 預設使用的埠是localhost:2181，(若2181埠被佔用殺掉程序sudo fuser -k 2181/tcp)

sudo bin/zookeeper-server-start.sh config/zookeeper.properties

# 能看到一堆列印資訊，其中有如下資訊，顯示啟動成功：
[
 
2021-08-10 20:37:18,482] INFO binding to port 0.0.0.0/0.0.0.0:2181

用bin/zookeeper-shell.sh連線ZK，顯示如下資訊即是成功：

bin/zookeeper-shell.sh localhost:2181


Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null

停止ZK命令：

sudo bin/zookeeper-server-stop.sh

5. 使用預設引數啟動kafka，預設使用埠localhost:9092：

# 除錯的時候去掉-daemon，這樣日誌能夠顯示出來
sudo bin/kafka-server-start.sh config/server.properties

# 連線ZK成功會列印下面的日誌：
[2021-08-10 20:52:06,499] INFO starting (kafka.server.KafkaServer)
[2021-08-10 20:52:06,499] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
[2021
 
-08-10 20:52:06,572] INFO Socket connection established, initiating session, client: /127.0.0.1:56418, server: localhost/127.0.0.1:2181 (org.apache.zookeeper.ClientCnxn)

# 除錯穩定後使用此命令後臺執行
# sudo bin/kafka-server-start.sh -daemon config/server.properties

# 停止kafka
sudo bin/kafka-server-stop.sh

6. 新建Topic,Name是first

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

# 建立成功提示：
# Created topic first.

# 查詢建立的topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

7. 生產者，消費者：

# 生產者準備生產
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first
>ii
>aaa
>

# 消費者從頭開始消費
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic first
ii
aaa

# 刪除topic first
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic first

參考：

https://kafka.apache.org/quickstart官方快速指導

https://www.w3cschool.cn/apache_kafka/apache_kafka_basic_operations.htmlApache Kafka 基本操作

https://xuzheng.blog.csdn.net/article/details/106873063Kafka的學習和使用

https://support.huaweicloud.com/devg-kafka/Kafka-java-demo.htmlKafka Java客戶端接入示例

電信校園卡300一年500兩年20GB+10GB通用流量200分鐘通話30GB定向流量 v:13641304639

如果沒有一直堅持，也不會有質的飛躍，當生命有了限度，每個人的價值就會浮現。

船長部落格，期待共同交流提高!

本文如對您有幫助，記得點選右下邊小球【贊一下】，熱烈期待您關注部落格 n(*≧▽≦*)n