windows 環境使用 kafka

近來學習 kafka，網上搜的教程好多不好用。在此開一貼記錄一下學習過程。推薦官網，是最好的教程 

官網上是linux 環境，我用的是windows 環境。已經安裝過jdk

2 解壓，我把它解壓到 d:\server\kafka2.12，路徑中最好不要有空格

3 修改配置檔案 config 目錄下的 zookeeper.properties 和 server.properties，

3.1 zookeeper.properties 配置檔案修改資料儲存目錄

datadir=d:/server/kafka2.12/zookeeper-logs

3.2 server.properties 修改資料儲存目錄

log.dirs=d:/server/kafka2.12/kafka-logs

在解壓目錄下，執行以下命令。目錄裡有 bin 目錄

3.3 啟動 zookeeper 服務

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

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

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

5 使用如下命令檢視建立的主題列表：

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

6 啟動生產者：

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test1

7 啟動consumer：

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning

8 進行測試

在 producer 終端輸入字串，在 consumer 終端可以看到所有的輸入

CVS使用 windows環境下

經驗 1，wincvs中執行checkout動作的單位是 module 即匯入cvs倉庫的專案名稱。import時有設定，要記好。2，cvsroot pserver username password localhost 倉庫名 3，初始化乙個cvs倉庫，並將乙個現有專案匯入到cvs中 1 通過cv...

kafka創耳機 生產環境一鍵建立kafka集群

前段時間公司的乙個kafka集群出現了故障，由於之前準備不足，當時處理的比較慌亂。如 由於kafka的集群裡topic數量較多，並且每個topic的分割槽數量和副本數量都不是一樣的，如果按部就班的乙個乙個的去建立佇列，估計集群恢復時黃瓜菜都涼了。對於kafka集群出現故障，最快的處理辦法，就是重建集...

windows環境變數 set使用

一 檢視所有環境變數的名稱和值 linux下 export windows下 set 二 根據名稱查該環境變數的值 linux下 echo 環境變數名 比如 echo oracle home windows下 set 環境變數名 set設 置windows 環境變數 在cmd中設定只 對當前的cmd...