zookeeper
一构订、下載好之后在根目錄添加data和log文件夾
二侮叮、將conf目錄下的zoo_sample.cfg文件，復(fù)制一份悼瘾，重命名為zoo.cfg囊榜，修改zoo.cfg配置文件，dataDir和dataLogDir
dataDir=E:\\ProgramFile\\apache-zookeeper-3.5.6-bin\\data
dataLogDir=E:\\ProgramFile\\apache-zookeeper-3.5.6-bin\\log
三亥宿，設(shè)置環(huán)境變量卸勺，在系統(tǒng)環(huán)境變量添加ZOOKEEPER_HOME名，地址是指向你的zk包地址
ZOOKEEPER_HOME:E:\ProgramFile\apache-zookeeper-3.5.6-bin
- 1> %ZOOKEEPER_HOME%\bin
- 2> %ZOOKEEPER_HOME%\conf
四烫扼、進(jìn)入本地的E:\ProgramFile\apache-zookeeper-3.5.6-bin\bin
點(diǎn)擊 zkServer.cmd 進(jìn)行啟動(dòng)
五曙求、如果沒(méi)有閃退，打開(kāi)zkServer.cmd，然后打開(kāi)zkCli.cmd悟狱，證明zookeeper已經(jīng)配置成功静浴，如下圖
kafka
一、編輯kafka的配置文件挤渐，E:\ProgramFile\kafka_2.12-2.7.0\config\server.properties
二苹享、找到并編輯log.dirs=E:\ProgramFile\kafka_2.12-2.7.0\log, (自定義文件夾)
三、找到并編輯zookeeper.connect=localhost:2181浴麻。表示本地運(yùn)行(默認(rèn)的可以不改)
四得问、Kafka會(huì)按照默認(rèn)，在9092端口上運(yùn)行软免，并連接zookeeper的默認(rèn)端口：2181椭赋。
//如果要修改端口號(hào)，端口號(hào)小于1024時(shí)或杠，要用root權(quán)限啟動(dòng)kafka
config下
1哪怔、server.properties
port = 8100不指定的話(huà)，按照默認(rèn)9092
2向抢、connect-distributed.properties
bootstrap.servers=localhost:8100
3认境、producer.properties
bootstrap.servers=localhost:8100
4、connect-standalone.properties
bootstrap.servers=localhost:8100
5挟鸠、consumer.properties
bootstrap.servers=localhost:8100
運(yùn)行及測(cè)試
在啟動(dòng)Kafka前叉信，先運(yùn)行Zookeeper實(shí)例。 (前面的cmd命令:zkserver)
①啟動(dòng)Kafka服務(wù)器
cd E:\ProgramFile\kafka_2.12-2.7.0
.\bin\windows\kafka-server-start.bat .\config\server.properties
②創(chuàng)建主題
新建cmd窗口:
cd E:\ProgramFile\kafka_2.12-2.7.0\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
③創(chuàng)建生產(chǎn)者
新建cmd窗口:（我這邊修改過(guò)端口 所以用的8100端口艘希，默認(rèn)9092Ｅ鹕怼！）
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-producer.bat --broker-list localhost:8100 --topic test2
④創(chuàng)建消費(fèi)者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:8100 --topic test2 --from-beginning
**本文轉(zhuǎn)自博客園“葉丶梓軒”覆享，因?yàn)樽约阂残枰硪环菁阉欤矣行┳约阂⒁獾狞c(diǎn)需要添加 ** 原文鏈接
