kafka window安裝與配置

2022-06-19 07:09:16 字數 1836 閱讀 4894

一、安裝jdk1.8

(此處省略)

2. 在系統變數中新增zookeeper_home = c:\users\wcy\downloads\compressed\zookeeper-3.4.10

3. 編輯path系統變數,新增為路徑%zookeeper_home%\bin;

4. 將conf下「zoo_sample.cfg」重新命名為「zoo.cfg」

5. 在任意文字編輯器(如notepad)中開啟zoo.cfg. 找到並編輯datadir=c:/datadir

6. 找到並編輯datadir=c:/datadir

7. 開啟新的cmd,輸入zkserver,執行zookeeper。

8. 命令列提示如下:說明本地zookeeper啟動成功

2.進入kafka配置目錄,c:\users\wcy\downloads\kafka_2.11-1.0.0\config ,編輯檔案「server.properties」 新增自己的日記目錄:log.dirs=...   同時開啟注釋 listeners=plaintext://:9092。如果zookeeper在某些其他的機器或集群上執行,可以將「zookeeper.connect:2181」修改為自定義ip與埠。在這裡使用了同乙個機器,所以沒其他做修改。檔案中的kafka埠和broker.id也是可以配置的。預設設定不變。

3.在zookeeper的基礎上,執行kafka服務 

進入kafka安裝目錄,c:\users\wcy\downloads\kafka_2.11-1.0.0

切換到命令列視窗,執行kafka。 

.\bin\windows\kafka-server-start.bat .\config\server.properties

執行成功,會有log檔案的輸出,連線zk的2181埠,啟動預設的9092埠

四、測試

a、建立主題 

1. 現在建立主題,命名為「test」,replication factor=1(因為只有1個kafka伺服器在執行)。如果集群中所執行的kafka伺服器不止1個,可以相應增加replication-factor,從而提高資料可用性和系統容錯性。

2. 在c:\users\wcy\downloads\kafka_2.11-1.0.0\bin\windows開啟新的命令列。 

3. 輸入下面的命令,回車:kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test 

b. 建立producer及consumer來測試伺服器。 

1.在c:\users\wcy\downloads\kafka_2.11-1.0.0\bin\windows開啟新的命令列。 

2.輸入以下命令,啟動producer,可以輸入訊息:kafka-console-producer.bat –broker-list localhost:9092 –topic test 

3.在同樣的位置c:\users\wcy\downloads\kafka_2.11-1.0.0\bin\windows再次開啟新的命令列。 

4.現在輸入下列命令啟動consumer,可以獲取訊息:kafka-console-consumer.bat –zookeeper localhost:2181 –topic test 

5.兩個命令列視窗,producer可以輸入任何訊息,consumer可以獲取訊息。

centos redis 安裝啟動與配

yum install epel release 安裝擴充套件源 yum install redis 安裝redisvim etc redis.conf 找到下面這一行 bind 127.0.0.1 注釋掉service redis start 啟動服務在配置檔案中有個引數 requirepass ...

supervisor和Nginx安裝與配置

gugoo雲之summary sudo apt get purge remove nginx sudo apt get autoremove dpkg get selections grep nginx 將羅列出與nginx相關的軟體,如nginx common一併刪除 sudo apt get p...

RHEL CentOS中vsftp安裝與配置

一般我們在安裝完系統後都會自動安裝了vsftp服務了,但是有時候還是得需要自己動手的,比如這兩天就在給我朋友配置了一下,順手把過程記錄下來,以便需要的時候查閱或者給需要的朋友提供方便 1.安裝 使用 chkconfig list來檢視是否裝有vsftpd服務 使用yum命令直接安裝 yum y in...