kafka目錄結構
bin linux系統下可執行腳本文件
bin/windows windows系統下可執行腳本文件
config 配置文件
libs 依賴類庫
licenses 許可信息
site-docs 文檔
logs 服務日志
啟動ZooKeeper
進入Kafka解壓縮文件夾的config目錄,修改zookeeper.properties配置文件
#the directory where the snapshot is stored.
#修改dataDir配置,用于設置ZooKeeper數據存儲位置,該路徑如果不存在會自動創建。
dataDir=E:/kafka_2.12-3.6.1/data/zk
打開DOS窗口
#因為當前目錄為windows,所以需要通過相對路徑找到zookeeper的配置文件。
zookeeper-server-start.bat …/…/config/zookeeper.properties
出現如下界面,ZooKeeper啟動成功
為了操作方便,也可以在kafka解壓縮后的目錄中,創建腳本文件zk.cmd。
#調用啟動命令,且同時指定配置文件。
call bin/windows/zookeeper-server-start.bat config/zookeeper.properties
啟動Kafka
進入Kafka解壓縮文件夾的config目錄,修改server.properties配置文件
#Listener name, hostname and port the broker will advertise to clients.
#If not set, it uses the value for “listeners”.
#客戶端訪問Kafka服務器時,默認連接的服務為本機的端口9092,如果想要改變,可以修改如下配置
#此處我們不做任何改變,默認即可
#advertised.listeners=PLAINTEXT://your.host.name:9092
#A comma separated list of directories under which to store log files
#配置Kafka數據的存放位置,如果文件目錄不存在,會自動生成。
log.dirs=E:/kafka_2.12-3.6.1/data/kafka
打開DOS窗口, 進入kafka/bin/windows目錄
調用啟動指令,傳遞配置文件的路徑
#因為當前目錄為windows,所以需要通過相對路徑找到kafka的配置文件。
kafka-server-start.bat …/…/config/server.properties
出現如下界面,Kafka啟動成功。
為了操作方便,也可以在kafka解壓縮后的目錄中,創建腳本文件kfk.cmd。
#調用啟動命令,且同時指定配置文件。
call bin/windows/kafka-server-start.bat config/server.properties
DOS窗口中,輸入jps指令,查看當前啟動的軟件進程
這里名稱為QuorumPeerMain的就是ZooKeeper軟件進程,名稱為Kafka的就是Kafka系統進程。此時,說明Kafka已經可以正常使用了。