<address id="5llnp"><pre id="5llnp"><span id="5llnp"></span></pre></address>

    <track id="5llnp"><strike id="5llnp"></strike></track>

    <pre id="5llnp"><ruby id="5llnp"></ruby></pre>

      
      <address id="5llnp"><strike id="5llnp"><span id="5llnp"></span></strike></address>
          <pre id="5llnp"></pre>
            <track id="5llnp"></track>
            您的位置:首頁 >聚焦 >

            天天信息:Kafka 安裝和基本操作

            2022-08-10 17:46:13    來源:程序員客棧

            大家好,我是 frank。歡迎大家點擊上方藍色文字「編程極客」關注公眾號。設為星標,第一時間接收推送文章。

            01?


            (相關資料圖)

            介紹

            Apache Kafka 是目前使用非常廣泛的消息引擎系統(Messaging System), 主要用于在不同系統之間傳遞消息。

            Kafka 是一個分布式系統,分為服務端和客戶端,它們之間通過 TCP 網絡協議進行通信。

            關于服務端和客戶端的詳細內容,本文我們暫不介紹。

            本文我們主要介紹 Kafka 的安裝和基本操作。

            02?

            安裝

            Kafka 安裝非常簡單,以目前最新版本?kafka_2.13-3.2.1為例,我們介紹一下 Kafka 的安裝步驟。

            需要注意的是,Kafka 的運行環境依賴 Java,所以我們還需要安裝 Java 8+ 環境。

            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 只需解壓縮文件,然后進入?kafka_2.13-3.2.1目錄。

            03?

            基本操作

            Kafka 安裝完成后,我們介紹一些 Kafka 的基本操作。

            啟動 Zookeeper 服務和 Kafka broke 服務

            打開終端,啟動 Zookeeper 服務。

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

            新打開一個終端,啟動 Kafka broke 服務。

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

            關于 Zookeeper 和 Kafka broke 的詳細內容,本文暫不介紹。

            創建一個 Topic 存儲消息

            新打開一個終端,創建一個 topic。

            bin/kafka-topics.sh?--create?--topic?quickstart-events?--bootstrap-server?localhost:9092

            細心的讀者朋友們可能已經發現,上述使用的三個 Kafka 命令行工具都有其他選項,實際上,Kafka 的所有命令行工具都有其他選項。

            如果我們想要查看命令行工具的其他選項,只需運行沒有任何參數的命令行,即可查看使用信息。

            如果想要查看新創建 topic 的詳細信息,可以使用選項?--describe,完整命令:

            bin/kafka-topics.sh?--describe?--topic?quickstart-events?--bootstrap-server?localhost:9092

            關于 Kafka 命令行工具其他選項的使用信息,本文暫不介紹。

            將消息寫入 topic?Kafka 客戶端分為生產者和消費者,通過網絡與 Kafka brokers 通信,其中,生產者負責將消息寫入 topic。

            新打開一個終端,使用生產者客戶端將消息寫入 topic。

            bin/kafka-console-producer.sh?--topic?quickstart-events?--bootstrap-server?localhost:9092

            默認情況,每輸入一行內容,都將寫入 topic 一條消息。

            可以隨時使用?Ctrl-C退出生產者客戶端。

            讀取 topic 中的消息?新打開一個終端,使用消費者客戶端讀取 topic 中的消息。

            bin/kafka-console-consumer.sh?--topic?quickstart-events?--from-beginning?--bootstrap-server?localhost:9092

            可以隨時使用?Ctrl-C退出消費者客戶端。

            消息是持久存儲在 Kafka 中,我們可以根據需要使用任意數量消費者讀取 topic 中的消息。

            選項?--from-beginning代表從頭讀取該 topic 的所有消息。

            關閉 Kafka

            如果你還未停止生產者和消費者,首先在生成者和消費者的終端,分別使用?Ctrl-C退出客戶端;

            然后,使用?Ctrl-C退出 Kafka broker;

            最后,使用?Ctrl-C退出 ZooKeeper 服務。

            如果你想徹底刪除上述操作產生的所有數據,可以執行命令?rm -rf /tmp/kafka-logs /tmp/zookeeper。

            04?

            總結

            本文我們簡單介紹 Kafka 是什么,和有什么用,然后介紹了怎么安裝 Kafka 和一些基本操作。

            通過閱讀完本文的所有內容,讀者朋友們可以先在自己電腦上安裝 Kafka,并實際操作本文提到的基本操作。

            關鍵詞: 基本操作 下載地址 引擎系統

            相關閱讀

            诱人的瑜伽老师HD中字

              <address id="5llnp"><pre id="5llnp"><span id="5llnp"></span></pre></address>

              <track id="5llnp"><strike id="5llnp"></strike></track>

              <pre id="5llnp"><ruby id="5llnp"></ruby></pre>

                
                <address id="5llnp"><strike id="5llnp"><span id="5llnp"></span></strike></address>
                    <pre id="5llnp"></pre>
                      <track id="5llnp"></track>