Kafka安裝與簡介 單機版 web頁面

2021-09-01 02:37:49 字數 1274 閱讀 1583

請查閱：

注：在bin/目錄下新建start.sh指令碼，具體**為：

sh kafka-server-start.sh ../config/server.properties 1>/dev/null  2>&1  &
其中1>/dev/null  2>&1 是將命令產生的輸入和錯誤都輸入到空裝置，也就是不輸出的意思。/dev/null代表空裝置。

輸入命令，sh start.sh 啟動kafka。

listeners = plaintext://ip:9092
注：產生訊息、消費訊息指令碼中的ip 必須要與配置檔案中的listener 中的ip 相同新建topic：

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic ab
產生訊息：

./kafka-console-producer.sh --broker-list ip:9092 --topic ab
消費訊息（一般0.9.0以上版本都有以下命令）：

./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic ab --from-beginning

kafka-manager.zkhosts="localhost:2181"
進入 bin 目錄下，直接輸入命令：kafka-manager ,即可開啟，頁面訪問 ip:9000

設定 kafka-manager後台啟動，新建 start.sh 檔案，指令碼為：

sh start.sh
其中 port 可以自己設定埠，預設為9000

關閉kafka-manager ,查詢服務，殺死程序即可

ps -ef|grep kafka-manager
再啟動kafka-manager 時，必須要先清除 kafka-manager-1.3.3.7 目錄下的 running_pid,否則會報已啟動

rm -rf running_pid

單機版kafka安裝

export server kafka kafka安裝需要有zookeeper註冊中心 其中 zookeeper的安裝 見centos7安裝偽分布式zookeeper root vm 0 2 centos kafka wget2.解壓 root vm 0 2 centos kafka tar zxv...

單機版kafka安裝

wget解壓安裝包 tar xzvf kafka 2.11 2.0.0.tgz修改server.properties檔案 vim kafka 2.11 2.0.0 config server.properties listeners plaintext advertised.listeners pl...

kafka單機版安裝

參考文件 192.168.1.183 centos 6.5 2.6.32 431.el6.x86 64 三部曲 jdk zookeeper kafka 嚴格的安裝順序 wget wget 1 基本的系統操作 關閉防火牆 時間同步 相關工具.2 安裝jdk root kafka cd usr loca...