1. 安裝包:kafka_2.11-1.1.0.tgz
2. 把安裝包放在/data/program/資料夾下,如果沒有program資料夾,則建立乙個
# mkdir program
3. 解壓
# tar -zxvf kafka_2.11-1.1.0.tgz
4. 修改/config/server.propeties配置檔案
kafka依賴zookeeper,所以需要提前啟動zookeeper
修改配置檔案的zookeeper連線址
zookeeper.connect=192.168.110.128:2181
5. 啟動:bin目錄下,後台啟動:
#./kafka-server-start.sh -daemon ../config/server.properties
控制台啟動
#./kafka-server-start.sh ../config/server.properties
6. 關閉kafka, bin目錄下
#./kafka-server-stop.sh
7. 建立topic,bin目錄下
#./kafka-topics.sh --create --zookeeper 192.168.110.128:2181 --replication-factor 1 --partitions 1 --topic test
8. 檢視topic, bin目錄下
#./kafka-topics.sh --list --zookeeper 192.168.110.128:2181
9. 發布訊息,bin目錄下
#./kafka-console-producer.sh --broker-list 192.168.110.128:9092 --topic test
10. 監聽訊息,bin目錄下
#./kafka-console-consumer.sh --bootstrap-server 192.168.110.128:9092 --topic test --from-beginning
11. 檢視topic詳情,bin目錄下
#./kafka-topics.sh --describe --zookeeper 192.168.33.63:2181 --topic test
修改/config/server.propeties配置檔案
broker.id=2 (id是集群中唯一的)
listeners=plaintext: (設定監聽ip)
Linux系統安裝kafka步驟
記錄一下在aliyun linux伺服器上安裝kafka的過程 本次安裝的kafka版本為kafka 2.11 2.1.0 注意 kafka的執行依賴於zookeeper 我在安裝kafka之前已經安裝好了zookeeper 並啟動zookeeper 安裝步驟如下 2.上傳到 usr local k...
Kafka 安裝教程(詳細步驟)
注意,須有前置環境 zookeeper 提取碼 q741 tar zxf opt kafka 2.11 2.0.0.tgz 建議將所有軟體移動至統一目錄下 mv kafka 2.11 2.0.0 opt soft kafka211 進入config目錄,並修改server檔案 cd opt soft...
Kafka 2 0 0安裝步驟及集群
首先確認安裝jdk8及以上版本,確認已安裝zookeeper,zookeeper 3.4.12安裝步驟 選擇 kafka 2.11 2.0.0.tgz版本,複製到安裝目錄,解壓縮 第二步 修改配置檔案 borker的編號,如果集群中有多個,則每個borker需設定不同的編號 broker.id 0 ...