kafka安装、配置、启动、常用命令及shell启动脚本编写
config? :kafka配置文件所在目錄
server.properties??? 主要配置文件
zookeeper.properties?? kafka內(nèi)置了zk,一般要將其替換掉
以下關(guān)于生產(chǎn)者和消費(fèi)者的配置主要是在命令行場(chǎng)景使用:
producer.properties
consumer.properties
broker.id?? 服務(wù)器id
delete.topic.enable???? topic是否可以刪除(一般允許刪除)
線(xiàn)程數(shù)和socket相關(guān)配置:
log.dirs
配置zk
?
常用命令:
kafka-server-start.sh??? 啟動(dòng)
kafka-server-stop.sh??? 停止
kafka-topics.sh??? topic的crud
kafka-console-producer.sh??? 命令行進(jìn)行producer測(cè)試
kafka-console-consumer.sh??? 命令行進(jìn)行consumer測(cè)試
啟動(dòng)
daemon啟動(dòng):
jps驗(yàn)證:
批量啟動(dòng)kafka腳本:
bin目錄 vi kk.sh? 復(fù)制下圖shell腳本
?
總結(jié)
以上是生活随笔為你收集整理的kafka安装、配置、启动、常用命令及shell启动脚本编写的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Spark集群搭建+基于zookeepe
- 下一篇: kafka-topics.sh top