日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 运维知识 > windows >内容正文

windows

Windows单机配置Kafka环境

發布時間:2024/4/15 windows 34 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Windows单机配置Kafka环境 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

首先確保機器已經安裝好Zookeeper,Zookeeper安裝參考 Windows單機配置Zookeeper環境

然后確保Zookeeper是正常啟動狀態

下載Kafka

http://kafka.apache.org/downloads.html

下載二進制包

下載后解壓縮,我這里解壓縮到了 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄

解壓縮

?

首先建立一個空文件夾 logs

建立logs文件夾

進入config目錄,編輯 server.properties 文件

編輯server.properties

修改 log.dirs 屬性部分的地址

修改log.dirs屬性

?

然后在 D:\WorkSoftware\kafka_2.11_0.10.1.0 目錄,按住shift+鼠標右鍵

在此處打開命令窗口

然后輸入下面命令

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

回車,執行命令

出現錯誤

如果出現錯誤,我這里分析是CLASSPATH沒有配置正確,那么,先設置CLASSPATH,然后再執行

SET CLASSPATH=.; 設置CLASSPATH 成功

測試一下,首先進入 D:\WorkSoftware\kafka_2.11-0.10.1.0\bin\windows 目錄,然后在當前目錄打開命令窗口

輸入下面命令,創建一個topic

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic

如果還遇到無法加載類等錯誤,還是先設置CLASSPATH

遇到無法加載主類,需要設置CLASSPATH topic創建成功

打開一個Producer

kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic 執行命令,打開生產者

這三個窗口不關閉的情況下(zookeeper/kafka/producer),再次開啟一個命令窗口(還是在kafka目錄右鍵打開),輸入下面命令,開啟Consumer

kafka-console-consumer.bat --zookeeper localhost:2181 --topic test.topic

這樣,這里就有4個命令窗口

分別是

  • Zookeeper
  • Kafka
  • Producer
  • Consumer
  • 下面,我們在3號窗口(Producer)輸入一些字符,就會看到4號窗口馬上就收到消息

    至此,Kafka的Windows單機環境搭建完畢



    作者:sphsyv
    鏈接:https://www.jianshu.com/p/64d25dcf8300
    來源:簡書
    簡書著作權歸作者所有,任何形式的轉載都請聯系作者獲得授權并注明出處。

    轉載于:https://www.cnblogs.com/houxinxin/p/9188973.html

    總結

    以上是生活随笔為你收集整理的Windows单机配置Kafka环境的全部內容,希望文章能夠幫你解決所遇到的問題。

    如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。