windows環境kafka服務搭建

2021-09-13 01:26:56 字數 1706 閱讀 2721

kafka配置

kafka簡單演示

參考**

kafka是用於構建實時資料管道和流應用程式。具有橫向擴充套件,容錯,wicked fast(**快)等優點,並已在成千上萬家公司執行。

詳細可檢視官網:

以下進入主題,環境搭建

本示例使用版本是zookeeper-3.4.13

配置環境變數

在系統環境變數中新增:zookeeper_home=d:\programdata\zookeeper-3.4.13

在系統變數中的path變數,增加%zookeeper_home%\bin

開啟cmd視窗,輸入zkserver,執行zookeeper,執行結果如下:

至此,zookeeper安裝並配置完畢;

請確保啟動kafka伺服器前,zookeeper例項已經在執行,因為kafka的執行是需要zookeeper這種分布式應用程式協調服務。

kafka啟動視窗不要關閉。

生產者與消費者分別開視窗,切不要關閉

進入kafka安裝目錄d:\programdata\kafka_2.11-2.1.1,按下shift+滑鼠右鍵,選擇"在此處開啟命令視窗",開啟命令列。

在命令列中輸入:.\bin\windows\kafka-server-start.bat .\config\server.properties 按下回車,啟動kafka服務

建立乙個名為「test」的主題,它只包含乙個分割槽,只有乙個副本:

進入目錄:d:\programdata\kafka_2.11-2.1.1\bin\windows,開啟命令視窗,執行如下命令:

>.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-fac

tor 1 --partitions 1 --topic test

成功後控制台列印如下資訊:

如果我們執行list topic命令,我們現在可以看到該主題:

>.\kafka-topics.bat --list --zookeeper localhost:2181

test

kafka附帶乙個命令列客戶端,它將從檔案或標準輸入中獲取輸入,並將其作為訊息傳送到kafka集群。預設情況下,每行將作為單獨的訊息傳送。

執行生產者,然後在控制台中鍵入一些訊息以傳送到伺服器:如 hello sunny!

>.\kafka-console-producer.bat --broker-list localhost:9092 --topic test

hello sunny!

kafka還有乙個命令列使用者,它會將訊息轉儲到標準輸出,此時,你會看到介面上輸出hello sunny!

>.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic t

est --from-beginning

hello sunny!

本篇部分內容參考了 進行編寫,感謝「我有一顆明珠」的熱心分享。後面命令執行部分,基本按照kafka官網的命令進行:quickstar

windows 環境使用 kafka

近來學習 kafka,網上搜的教程好多不好用。在此開一貼記錄一下學習過程。推薦官網,是最好的教程 官網上是linux 環境,我用的是windows 環境。已經安裝過jdk 2 解壓,我把它解壓到 d server kafka2.12,路徑中最好不要有空格 3 修改配置檔案 config 目錄下的 z...

Windows環境下mosquitto伺服器搭建

安裝完成後,安裝資料夾下部分檔案的功能 模組功能 mosquitto.conf mosquitto伺服器的配置檔案 mosquitto 用來開啟broker mosquitto passwd 用來設定使用者的賬號與密碼 mosquitto pub 用來發布訊息 mosquitto sub 用來訂閱訊...

Kafka單機Windows環境搭建

kafka單機windows環境搭建 1,安裝jdk1.8 安裝目錄不能有中文空格 解壓到d zookeeper 3.4.11之後,在conf目錄下面重新命名zoo sample.cfg為zoo.cfg,在zoo.cfg修改如下內容 datadir d zookeeper 3.4.11 data d...