單機版kafka的搭建

2021-08-21 02:33:25 字數 1873 閱讀 1402

環境 centos7    jdk1.8    zookeeper3.4.10   kafka2.11

操作前開啟2181和9092埠

1.安裝zookeeper

wget
tar -zxvf zookeeper-3.4.10.tar.gz
cd zookeeper-3.4.10/conf
將zoo_sample.cfg複製乙份改為zoo.cfg

cp zoo_sample.cfg zoo.cfg
編輯zoo.cfg

vim zoo.cfg
編輯之後的內容

ticktime=2000


initlimit=10


synclimit=5


#目錄自行建立


datadir=/tmp/zookeeper


datalogdir=/var/log/kafka/zk


clientport=2181


server.1=[你的host]:2888:3888
具體配置自行查閱相關資料

進入bin目錄，啟動，重啟，停止，檢視狀態命令如下

./zkserver.sh start


./zkserver.sh stop


./zkserver.sh restart


./zkserver.sh status
若啟動失敗，檢視配置檔案中的日誌資料夾是否建立

2.安裝kafka

wget
tar -zxvf kafka_2.11-1.1.0.tgz
進入目錄，修改配置檔案

cd kafka_2.11-1.1.0/config
vim server.properties
開啟注釋
#listeners=plaintext://:9092


#advertised.listeners=plaintext:
進行相應的更改 

更改zookeeper的配置，將localhost改為你的zookeeper位址，若zookeeper在本地可以不用修改

儲存啟動kafka

進入bin目錄執行如下命令

(./kafka-server-start.sh config/server.properties &)
保持後台執行

測試建立乙個名叫test的topic

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
檢視所有的topic

./kafka-topics.sh --list --zookeeper localhost:2181
傳送訊息

./kafka-console-producer.sh --broker-list localhost:9092 --topic test
輸入 hello kafka

接收訊息

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
可以收到 hello kafka 的訊息

參考

單機版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...