Kafka 安裝和基本操作
大家好，我是 frank。
歡迎大家點(diǎn)擊上方藍(lán)色文字「編程極客」關(guān)注公眾號。
設(shè)為星標(biāo)，第一時(shí)間接收推送文章。
01
介紹
Apache Kafka 是目前使用非常廣泛的消息引擎系統(tǒng)（Messaging System）， 主要用于在不同系統(tǒng)之間傳遞消息。
Kafka 是一個(gè)分布式系統(tǒng)，分為服務(wù)端和客戶端，它們之間通過 TCP 網(wǎng)絡(luò)協(xié)議進(jìn)行通信。
關(guān)于服務(wù)端和客戶端的詳細(xì)內(nèi)容，本文我們暫不介紹。
本文我們主要介紹 Kafka 的安裝和基本操作。
02
安裝
Kafka 安裝非常簡單，以目前最新版本 kafka_2.13-3.2.1 為例，我們介紹一下 Kafka 的安裝步驟。
需要注意的是，Kafka 的運(yùn)行環(huán)境依賴 Java，所以我們還需要安裝 Java 8+ 環(huán)境。
Java 下載地址：https://www.java.com/zh-CN/download/
Kafka 下載地址：https://dlcdn.apache.org/kafka/3.2.1/kafka_2.13-3.2.1.tgz
下載完 Java 和 Kafka，安裝也比較簡單，其中 Java 是圖形化安裝界面，Kafka 只需解壓縮文件，然后進(jìn)入 kafka_2.13-3.2.1 目錄。
03
基本操作
Kafka 安裝完成后，我們介紹一些 Kafka 的基本操作。
啟動 Zookeeper 服務(wù)和 Kafka broke 服務(wù)
打開終端，啟動 Zookeeper 服務(wù)。
bin/zookeeper-server-start.sh config/zookeeper.properties
新打開一個(gè)終端，啟動 Kafka broke 服務(wù)。
bin/kafka-server-start.sh config/server.properties
關(guān)于 Zookeeper 和 Kafka broke 的詳細(xì)內(nèi)容，本文暫不介紹。
創(chuàng)建一個(gè) Topic 存儲消息
新打開一個(gè)終端，創(chuàng)建一個(gè) topic。
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
細(xì)心的讀者朋友們可能已經(jīng)發(fā)現(xiàn)，上述使用的三個(gè) Kafka 命令行工具都有其他選項(xiàng)，實(shí)際上，Kafka 的所有命令行工具都有其他選項(xiàng)。
如果我們想要查看命令行工具的其他選項(xiàng)，只需運(yùn)行沒有任何參數(shù)的命令行，即可查看使用信息。
如果想要查看新創(chuàng)建 topic 的詳細(xì)信息，可以使用選項(xiàng) --describe，完整命令：
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
關(guān)于 Kafka 命令行工具其他選項(xiàng)的使用信息，本文暫不介紹。
將消息寫入 topic Kafka 客戶端分為生產(chǎn)者和消費(fèi)者，通過網(wǎng)絡(luò)與 Kafka brokers 通信，其中，生產(chǎn)者負(fù)責(zé)將消息寫入 topic。
新打開一個(gè)終端，使用生產(chǎn)者客戶端將消息寫入 topic。
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
默認(rèn)情況，每輸入一行內(nèi)容，都將寫入 topic 一條消息。
可以隨時(shí)使用 Ctrl-C 退出生產(chǎn)者客戶端。
讀取 topic 中的消息 新打開一個(gè)終端，使用消費(fèi)者客戶端讀取 topic 中的消息。
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
可以隨時(shí)使用 Ctrl-C 退出消費(fèi)者客戶端。
消息是持久存儲在 Kafka 中，我們可以根據(jù)需要使用任意數(shù)量消費(fèi)者讀取 topic 中的消息。
選項(xiàng)
--from-beginning代表從頭讀取該 topic 的所有消息。
關(guān)閉 Kafka
如果你還未停止生產(chǎn)者和消費(fèi)者，首先在生成者和消費(fèi)者的終端，分別使用 Ctrl-C 退出客戶端；
然后，使用 Ctrl-C 退出 Kafka broker；
最后，使用 Ctrl-C 退出 ZooKeeper 服務(wù)。
如果你想徹底刪除上述操作產(chǎn)生的所有數(shù)據(jù)，可以執(zhí)行命令
rm -rf /tmp/kafka-logs /tmp/zookeeper。
04
總結(jié)
本文我們簡單介紹 Kafka 是什么，和有什么用，然后介紹了怎么安裝 Kafka 和一些基本操作。
通過閱讀完本文的所有內(nèi)容，讀者朋友們可以先在自己電腦上安裝 Kafka，并實(shí)際操作本文提到的基本操作。
推薦閱讀：
參考資料：
https://kafka.apache.org/quickstart https://www.java.com/zh-CN/download/ https://dlcdn.apache.org/kafka/3.2.1/kafka_2.13-3.2.1.tgz
掃描二維碼，加入微信群
點(diǎn)「贊」和「在看」是最大的支持??
??更多精彩內(nèi)容，請點(diǎn)擊「閱讀原文」