引言

這篇文章是一篇Ubuntu(Linux)環境下的Kafka安裝與使用教程，通過本文，你可以非常快速搭建一個kafka的小單元進行日常開發與調測。

安裝步驟

下載與解壓安裝

首先我們需要下載一下Kafka，這里筆者采用wget指令：

 wget https://downloads.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz

完成下載后將項目解壓與重命名，方便后續的使用：

tar -xzf kafka_2.13-3.9.0.tgz
mv kafka_2.13-3.9.0 kafka

基本配置

打開config/server.properties文件，將ip改為你的服務器ip，

listeners=PLAINTEXT://x.x.x.x:9092
advertised.listeners=PLAINTEXT://x.x.x.x:9092

啟動測試

完成上述步驟之后，將zk啟動，觀測控制臺啟動是否無誤，無誤之后可以嘗試后臺啟動，這里筆者為了文章的精簡就不做過多演示了：

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

如下圖，成功綁定2181后即可說明zk啟動成功了：

同理將Kafka服務端啟動即可：

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

生產者與消費者收發調測

經過上述的基本配置之后，我們已經成功的將kafka服務端啟動了，以本文為例筆者的消費者會訂閱transactions 這個topic，對應的啟動指令為：

./bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic transactions --from-beginning

確認無誤后，將生產者直接啟動：

./bin/kafka-console-producer.sh --broker-list 172.19.182.7:9092 --topic transactions

隨后我們在生產者控制臺鍵入hello consumer：

[[Asharkchili@DESKTOP-xxxxxx:~/kafka$ ./bin/kafka-console-producer.sh --broker-list 172.19.182.7:9092 --topic transactions
>hello consumer
>

如果消費者接收消息成功，則說明本次kafka的基本配置與部署完成。

小結

參考

https://blog.csdn.net/m0_37903882/article/details/133893424