kafka的作用與原理就不在這裡說了,具體可以參考其他文章,本文主要講訴的是kafka單機安裝
wget
2.然後執行解壓命令tar -zxvf kafka_2.12-2.2.1.tgz 就可以得到相應的目錄(我的目錄為/mydata/sort/)
3.新建2個log目錄分別為/mydata/kafka/kafka_2.12-2.2.1/kafka_log 和/mydata/kafka/kafka_2.12-2.2.1/zookeeper_log .其作用是為了存放kafka的資料和zookeeper的資料
4.修改/config/zookeeper.properties 將clientport=2181 改為clientport=2182 這裡因為筆者的2181埠被占用,所以就修改為2182.如果各位的埠沒被占用則不需要改。 datadir為資料儲存路徑,修改為剛才新建的目錄datadir=/mydata/sort/kafka_2.12-2.2.1/zookeeper_log
5.修改/config/server.properties 配置檔案
a)將advertised.listeners的注釋開啟,然後修改為:advertised.listeners=plaintext://localhost:9092(9092是預設埠)
b)將log.dir 修改為上面新建的目錄:log.dirs=/mydata/sort/kafka_2.12-2.2.1/kafka_log
c)將zookeeper.connect修改為設定的埠位址。我這裡是zookeeper.connect=localhost:2182
6.基本的配置引數基本是配置完成了,接下來就是啟動了
a)bin/zookeeper-server-start.sh config/zookeeper.properties & 將zookeeper的服務啟動
b)bin/kafka-server-start.sh config/server.properties & 將kafka的服務啟動
7.當執行完以上命令後,就可以用jps語句看下有沒有kafka和quorumpeermain 2個服務,都有就代表成功了
8.我們可以進行測試下
a)先建立乙個佇列:bin/kafka-topics.sh --create --zookeeper localhost:2182 --replication-factor 1 --partitions 1 --topic test
b)再建立乙個生產者: bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 成功就會進入乙個右箭頭的輸入介面就代表成功了
c)最後將乙個消費者:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
這就是目前kafka的單機版本進行安裝和測試,集群也是差不多原理,只需要修改配置檔案和再相應的機器安裝和kafka和開啟好埠就好了
kafka 安裝(單機模式)
1.準備安裝包 上傳到目錄 opt kafka 解壓 tar zxvf kafka 2.12 1.0.0.tgz 2.修改配置檔案 config server.properties 引數預設值 參考數值 broker.id00 port 9092 9092 log.dirs tmp kafka lo...
kafka 學習(二)單機安裝kafka
參考 解壓後2.3.0才是kafka版本 2.12是kafka依賴的scala版本 kafka 2.12 2.3.0 kafka依賴於zookeeper 需安執行zookeeper,才能執行kafka kafka2.30這個版本內建了zookeeper 在kaka目錄下執行命令 bin window...
單機版kafka安裝
export server kafka kafka安裝需要有zookeeper註冊中心 其中 zookeeper的安裝 見centos7安裝偽分布式zookeeper root vm 0 2 centos kafka wget2.解壓 root vm 0 2 centos kafka tar zxv...