【kafka】 windows平臺搭建及使用

一、安裝

  • kafka 需要java環境;
  • kafka 最新版本內置了 zookeeper,所以不需要安裝zookeeper;
  • 下載kafka最新版本,因為下載的是tgz文件,所以不需要安裝,解壓到相應的地方就可以了。下載地址:http://kafka.apache.org/downloads(我使用的版本:kafka_2.11-1.1.0)
  • bin 目錄下放的是啟動kafka的文件,conf目錄下放的是kafka的各種配置文件。

? 總結:至此kafka在windows平臺上的搭建完成了。

二、使用:

? ? 簡單測試,查看是否ok。
?? ?PS:zookeeper默認端口:2181;生產者默認端口:9092
?? ?總結:
?? ??? ?簡單測試一共五步:
?? ??? ?1.啟動zookeeper
?? ??? ?2.啟動kafka
?? ??? ?3.創建主題topic
?? ??? ?4.啟動消費者 customer
?? ??? ?5.啟動生產者 producer
? ? ? ??

1.啟動zookeeper

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

2.啟動kafka

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

3.創建主題topic,并查看

創建命令:
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wzq
查看命令:
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181


4.啟動消費者 customer

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic wzq --from-beginning

5.啟動生產者 producer

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

PS:有五個黑窗口 1.zookeeper服務(不可關閉)?2.kafka服務(不可關閉) 3.創建主題(可關閉) 4.消費者(不可關閉) 5.生產者(不可關閉)。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/273689.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/273689.shtml
英文地址,請注明出處:http://en.pswp.cn/news/273689.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Unix/Linux環境C編程入門教程(16) LinuxMint CCPP開發環境搭建

1.Linux Mint由Linux Mint Team團隊于2006年開始發行,是一份基于Debian和Ubuntu的Linux發行版。其目標是提供一種更完整的即刻可用體驗,這包括提供瀏覽器插件、多媒體編解碼器、對DVD播放的支持、Java和其他組件,它也增加了一套定制桌面及各種…

@TableLogic注解表示邏輯刪除

TableLogic注解表示邏輯刪除 效果:在字段上加上這個注解再執行BaseMapper的刪除方法時,刪除方法會變成修改 場景: 1.實體類中屬性加上TableLogic, TableLogic private Integer dataStatus; 2.調用BaseMapper的deleteById(id)或…

圖片上傳至本地

1.配置文件 bootstrap.yml file:path:httpResURL: http://122.246.1.148:19086SAVE_PATH: /data/imagesresURI: /wzq/ 2.文件工具類 import cn.hutool.core.io.FileUtil; import com.vinsuan.park.platform.biz.FilePathConfig; import lombok.AllArgsConstructor; import lo…

html調用靜態json例子

html調用靜態json例子 1.json {"current": 2,"result": "success" } 1.html <!doctype html> <html> <head> <meta charset"utf-8"> <title></title> <script src"http://code.jquery.co…

Extjs發票管理系統

技術特點&#xff1a;Extjs框架&#xff0c;三層架構&#xff0c;Ajax,json 1.仿office2007菜單.介面美觀大方,可動態更改皮膚保存至cookie。 2,json數據源與實體類的相互轉換. 3.可下載桌面版登錄方式,統計在線人數. 4, chm操作手冊,方便操作人員熟悉. 功能描述&#xff1a; 1…

jQuery調用WebService返回JSON數據

相信大家都比較了解JSON格式的數據對于ajax的方便&#xff0c;不了解的可以從網上找一下這方面的資料來看一下&#xff0c;這里就不多說了&#xff0c;不清楚的可以在網上查一下&#xff0c;這里只說一下因為參數設置不當引起的取不到返回值的問題。 在用jQuery調用WebService的…

Docker---問題1:bash: vi: command not found/bash: vim: command not found

在使用docker時&#xff0c;有時候我們需要編輯配置文件&#xff0c;需要使用vim或者vi命令&#xff0c;發現&#xff1a; root64801a03b121:/etc/nginx/conf.d# vi default.conf bash: vi: command not found root64801a03b121:/etc/nginx/conf.d# vim default.conf bash: …

C# 獲取配置文件節點值

<?xml version"1.0" encoding"utf-8" ?><configuration> <appSettings> <add key"ManagerName" value"XXX" /> </appSettings> <connectionStrings> <add name"DataBase"…

WHENEVER SQLERROR EXIT SQL.SQLCODE

1.SQL>WHENEVER SQLERROR EXIT SQL.SQLCODE出現錯誤后終止SQL*Plus運行。2.SQL>WHENEVER SQLERROR SQL.SQLCODE EXIT ROLLBACK 除了之前的含義&#xff0c;還包括讓SQL*Plus在推出之前把所有還沒提交的變化回滾處理。轉載于:https://www.cnblogs.com/nuaa/p/3828473.html…

IDEA 快捷鍵終極大全

一、自動代碼 常用的有fori/sout/psvmTab即可生成循環、System.out、main方法等boilerplate樣板代碼 。 例如要輸入for(User user : users)只需輸入user.forTab &#xff1b; 再比如&#xff0c;要輸入Date birthday user.getBirthday()只需輸入user.getBirthday().varTab即…

數組中只出現一次的數字

題目&#xff1a;一個整型數組里&#xff0c;除了兩個數字以外&#xff0c;其他數字都出現了兩次&#xff0c;請寫程序找到這兩個只出現一次的數字。要求&#xff1a;時間復雜度為O(n),空間復雜度為O(1). 分析&#xff1a;看到這題&#xff0c;首先要明白&#xff0c;這是求兩個…

iOS工作筆記之NSClassFromString

id myObj [[NSClassFromString("MySpecialClass") alloc] init]; 和 id myObj [[MySpecialClass alloc] init]; 是一樣的。但是&#xff0c;如果你的程序中并不存在MySpecialClass這個類&#xff0c;下面的寫法會出錯&#xff0c;而上面的寫法只是返回一個空對象而…

Maven 使用bat批量清除本地倉庫的lastUpdated文件

echo off set REPOSITORY_PATHC:\Users\Administrator\.m2\repository rem 正在搜索... for /f "delims" %%i in (dir /b /s "%REPOSITORY_PATH%\*lastUpdated*") do ( del /s /q %%i ) rem 搜索完畢 pause 新建一個文件txt文件&#xff0c;把.txt后綴…

“ddl”有一個無效 SelectedValue,因為它不在項目列表中。

“ddl_ekt”有一個無效 SelectedValue,因為它不在項目列表中。 怎么回事 現象&#xff1a; 在用戶控件的page_load事件里綁定下拉框&#xff0c;報上面錯誤 解決&#xff1a; 將下拉框綁定&#xff0c;放在page_Init事件里 這可能跟服務器加載控件的生命過程有關系轉載于:https…

springbot 注入多實例

方式一&#xff1a; 在需要多實例的類上加入注解&#xff1a; Scope("prototype") 方式二&#xff1a; 在啟動類上加入&#xff1a; BeanScope(value ConfigurableBeanFactory.SCOPE_PROTOTYPE, proxyMode ScopedProxyMode.TARGET_CLASS)public PrototypeClass…

javascript日歷插件

javascript日歷插件 原文:javascript日歷插件javascript日歷插件 最近在嘗試著寫javascript日歷插件&#xff0c;所以也到github上看國外人日歷源碼&#xff0c;或者國內人寫的好點的&#xff0c;也在研究點&#xff0c;雖然看到網上有一大把的日歷控件&#xff0c;但是沒有幾個…

idea 重啟

1、通過File–>Invalidate Caches/Restar...進入重啟窗口 2、選擇自己所需要的重啟方式&#xff0c;四個按鈕&#xff0c;一共三種重啟方式&#xff1a; Invalidate and Restart 清空緩存并重啟。Invalidate 清除緩存&#xff0c;下次打開重啟。Cancel 取消。Just Restart …

Kernel Page Global Directory (PGD) of Page table of Process created in Linux Kernel

Kernel Page Global Directory (PGD) of User process created 在早期版本: 在fork一個進程的時候&#xff0c;必須建立進程自己的內核頁目錄項&#xff08;內核頁目錄項要與用戶空間的頁目錄放在同一個物理地址連續的頁面上&#xff0c;所以不能共享&#xff0c;但所有進程的內…

POI 導出文件以文件流形式返回

POI工具類 import java.io.UnsupportedEncodingException; import javax.servlet.http.HttpServletResponse; import org.apache.poi.hssf.usermodel.HSSFCell; import org.apache.poi.hssf.usermodel.HSSFCellStyle; import org.apache.poi.hssf.usermodel.HSSFRow; import o…

Json串和java對象進行轉時

json-lib-xxx.jarezmorph-xxx.jar //>依賴包 JsonConfig config new JsonConfig();//有選擇性的過濾掉一些屬性值 JSONUtils.getMorpherRegistry().registerMorpher( new DateMorpher(new String[] { "yyyy-MM-dd" }));//注冊一個json轉為java.util.date的日期格…