一、zookeeper安裝
1滋尉、下載zookeeper
下載地址http://mirror.bit.edu.cn/apache/ , http://mirror.bit.edu.cn/apache/zookeeper/
當(dāng)前時間201911,最新版本為3.5,因3.5還未文檔叛溢,所以下載zookeeper-3.4.14,
2劲适、解壓到指定目錄
在你解壓的xxx\zookeeper-3.4.14\conf 下找到zoo_sample.cfg 文件楷掉。 將文件名改成 zoo.cfg。打開 zoo.cfg 文件 霞势,修改
dataDir=/tmp/zookeeper為dataDir=xxx/zookeeper3.4.14/tmp/zookeeper烹植。
dataLogDir=xxx/DevSoft/zookeeper/zookeeper-3.4.14/log
3、啟動
通過 cmd 進(jìn)入dos命令窗口愕贡。命令窗口模式進(jìn)入zookeeper的bin目錄下草雕,輸入zkServer.cmd 回車。如下圖:
4.命令行操作
4.1 增加節(jié)點(diǎn)
創(chuàng)建普通節(jié)點(diǎn):
create /test test
4.2 查詢節(jié)點(diǎn)
查詢節(jié)點(diǎn)數(shù)據(jù):
get /test
查看根節(jié)點(diǎn)下子節(jié)點(diǎn):
ls /
4.3 修改節(jié)點(diǎn)
查詢節(jié)點(diǎn)數(shù)據(jù):
get /test
修改節(jié)點(diǎn)數(shù)據(jù):
set /test 456
4.4 刪除節(jié)點(diǎn)
刪除節(jié)點(diǎn):
delete /test
二固以、kafka安裝
1墩虹、下載kafka
下載地址http://mirror.bit.edu.cn/apache/kafka/,
http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
我選的2.3版本
2憨琳、解壓到指定目錄
下載后解壓到需要目錄诫钓,更改server.properties配置文件,更改如下參數(shù):
每一個broker在集群中的唯一標(biāo)示篙螟,要求是正數(shù)菌湃。在改變IP地址,不改變broker.id的話不會影響
broker.id=0
kafka監(jiān)聽地址闲擦。
listeners=PLAINTEXT://127.0.0.1:9092
kafka數(shù)據(jù)的存放地址(不是日志地址慢味,kafka的日志默認(rèn)在安裝目錄的logs文件夾下)场梆,多個地址的話用逗號分割 /tmp/kafka-logs-1墅冷,/tmp/kafka-logs-2
log.dirs=E:/DevSoft/kafka/kafka_2.12-2.3.0/log
打開doc黑窗口,并進(jìn)入kafka安裝目錄或油,windows機(jī)器輸入
kafka-server-start.bat config/server.properties寞忿,
如果報(bào)錯則將:
kafka-server-start.bat (全路徑)/config/server.properties,
linux機(jī)器xxx\bin\kafka-server-start.sh config/server.properties
3顶岸、命令行操作
一下所有命令都是在kafka安裝目錄下執(zhí)行下面命令腔彰。
3.1新建topics (主題名稱helloTets)
xxx\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 -partitions 1 --topic helloTets
或者
kafka-topics.sh --bootstrap-server localhost:9092 --create --topic helloTets --partitions 1 --replication-factor 1
3.2查看主題
kafka-topics.bat --zookeeper localhost:2181 --list
或
kafka-topics.bat --bootstrap-server localhost:9092 --list
3.3 更新topics
命令如下,但未測試成功
xxx\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --alter --topic TestTest --partitions 1
3.4 刪除topics
xxx\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --delete --topic test1
或者
kafka-topics.bat --bootstrap-server localhost:9092--delete --topic test1(kafka2.2以后用)
使用查看命令查看
但此次刪除非物理刪除辖佣,物理刪除需要修改kafaka配置文件server.properties霹抛, 添加delete.topic.enable=true,重啟kafka卷谈,之后通過kafka命令行就可以直接刪除topic
3.5生產(chǎn)者發(fā)送消息
kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic helloTets
3.6消費(fèi)者消費(fèi)消息
kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic helloTets --from-beginning
以上命令分為兩種杯拐, --bootstrap-server 和 --zookeeper
從kafka 2.2 版本開始, --bootstrap-server 逐漸成為標(biāo)準(zhǔn),用以替換 --zoookeeper 端逼,二者區(qū)別不大朗兵,但 Kafka 有一套自己的安全體系,用于安全認(rèn)證顶滩。 --zookeeper會繞過安全體系余掖。