<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ThinkChat2.0新版上線,更智能更精彩,支持會話、畫圖、視頻、閱讀、搜索等,送10W Token,即刻開啟你的AI之旅 廣告
                # Apache Kafka – Windows 10 入門 > 原文: [https://howtodoinjava.com/kafka/getting-started-windows-10/](https://howtodoinjava.com/kafka/getting-started-windows-10/) 學習**在 Windows 10** 上安裝 [Apache Kafka](https://howtodoinjava.com/kafka/tutorial-introduction/) 并執行與 Kafka 和 Zookeeper 相關的*啟動服務器*和**停止服務器**腳本。 我們還將通過創建主題,向其生成少量消息,然后使用用戶讀取用 Kafka 編寫的消息來驗證 Kafka 的安裝。 ## 1\. 先決條件 * **需要 Java8** 才能從 Kafka 網站運行最新下載。 * **Zookeeper** (用于存儲有關 Kafka 群集的元數據)也是必需的。 Kafka 首先內置了 Zookeeper。 但是建議在生產環境中單獨安裝 Zookeeper。 從其[官方網站](https://zookeeper.apache.org/releases.html)下載它。 * Kafka 可以在任何操作系統上運行。 推薦使用 linux 操作系統。 使用 Windows,Kafka 有一些已知的錯誤。 > 本教程適用于初學者,并且不使用單獨的 zookeeper 實例 - 保持簡單,僅專注于 Kafka。 ## 2\. 下載并安裝 Kafka * 從[官方網站](https://kafka.apache.org/downloads.html)下載 Kafka。 我今天下載了最新版本 2.5.0,文件名為“[`kafka_2.12-2.5.0.tgz`](https://www.apache.org/dyn/closer.cgi?path=/kafka/2.5.0/kafka_2.12-2.5.0.tgz)”。 * 將下載的文件復制到某個文件夾,然后使用`tar`命令將其解壓縮。 ```java > tar -xzf kafka_2.12-2.5.0.tgz ``` * 將提取的文件夾復制到所需位置。 我把它放在位置“`E:\devsetup\bigdata\kafka2.5`”中。 安裝幾乎完成了! ## 3\. 啟動和關閉 要啟動 Kafka,我們需要先**啟動 Zookeeper,然后再啟動 Kafka**。 我正在編寫小的批處理文件,這些文件首先移至 Kafka 安裝目錄,然后在新的命令提示符窗口中執行命令。 #### 3.1 啟動 Zookeeper 要啟動 Zookeeper,我們需要運行`zookeeper-server-start.bat`腳本并傳遞 zookeeper 配置文件路徑。 ```java cd E:\devsetup\bigdata\kafka2.5 start cmd /k bin\windows\zookeeper-server-start.bat config\zookeeper.properties ``` #### 3.2 啟動 Kafka 要啟動 Kafka,我們需要運行`kafka-server-start.bat`腳本并傳遞 Broker 配置文件路徑。 ```java cd E:\devsetup\bigdata\kafka2.5 start cmd /k bin\windows\kafka-server-start.bat config\server.properties ``` #### 3.3 關閉 Kafka 要停止 Kafka,我們需要運行`kafka-server-stop.bat`腳本。 ```java cd E:\devsetup\bigdata\kafka2.5 start cmd /k bin\windows\kafka-server-stop.bat ``` #### 3.4 關閉 Zookeeper 要停止 Zookeeper,我們需要運行`zookeeper-server-stop.bat`腳本。 ```java cd E:\devsetup\bigdata\kafka2.5 start cmd /k bin\windows\zookeeper-server-stop.bat ``` > 不要使用`CTRL+C`命令停止 zookeeper 和 kafka。 始終使用上面的`.bat`文件或命令。 否則可能會發生數據損壞。 ## 4\. 驗證 Kafka 安裝 首先,使用上述腳本啟動 Zookeeper 和 Kafka。 * 打開一個新的命令提示符,然后**創建一個新的 Kafka 主題**。 ```java > bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test //Output: Created topic test. ``` * 現在**列出所有主題**以驗證創建的主題是否存在于此列表中。 在這一步,我們只有一個主題。 ```java > bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092 //Output: test ``` * 現在列出所有主題,以驗證創建的主題是否存在于此列表中。 在這一步,我們只有一個主題。 ```java > bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092 //Output: test ``` * **產生一些消息**并提交給`test`主題。 我添加了兩個消息,即“`Hello`”和“`Kafka`”。 ```java > bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test ``` * **使用消息**并提交到`test`主題。 ```java > bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning //Output: Hello Kafka ``` ![](https://img.kancloud.cn/d5/a2/d5a29081d625cc6699df5e8af3c89d01_721x385.png) 驗證 Kafka 安裝 ## 5\. 總結 在本教程中,我們學習了與 Zookeeper 一起安裝 Kafka。 我們學會了啟動和停止這兩個服務器。 此外,我們通過創建主題,發布一些消息然后使用控制臺用戶腳本進行使用來驗證安裝。 需要注意的重要一點是,我們永遠不要通過殺死進程或`CTRL+C`命令來停止服務器。 始終使用腳本來停止服務器。 學習愉快! 參考: [源碼下載](https://github.com/lokeshgupta1981/Kafka)
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看