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附帶乙個命令列客戶端,它將從檔案或標準輸入中獲取輸入,並將其作為訊息傳送到kafka集群。預設情況下,每行將作為單獨的訊息傳送。>.\kafka-topics.bat --list --zookeeper localhost:2181
test
執行生產者,然後在控制台中鍵入一些訊息以傳送到伺服器:如 hello sunny!
kafka還有乙個命令列使用者,它會將訊息轉儲到標準輸出,此時,你會看到介面上輸出hello sunny!>.\kafka-console-producer.bat --broker-list localhost:9092 --topic test
hello sunny!
本篇部分內容參考了 進行編寫,感謝「我有一顆明珠」的熱心分享。後面命令執行部分,基本按照kafka官網的命令進行:quickstar>.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic t
est --from-beginning
hello sunny!
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...