kafka集群搭建

2022-08-25 16:18:25 字數 1719 閱讀 7311

#rz上傳包至/opt/install/


#解壓tar -zxvf kafka_2.12-0.10.2.1.tgz


#修改目錄名稱


mv kafka_2.12-0.10.2.1 kafka


#移動資料夾至/opt/software


#文尾新增環境變數


export kafka_home=/opt/software/kafka


export path=$path:$kafka_home/bin


#讓配置生效


#配置 broker 的id


broker.id=1 //第乙個kafka配置為 1，第二個配置為2，以此類推


#開啟監聽埠


listeners=plaintext: //盡量寫ip位址，以免造成錯誤


#修改 log 的目錄、在指定的位置建立好資料夾logs


log.dirs=/usr/local/kafka/logs


#修改 zookeeper.connect


zookeeper.connect=linux24:2181,linux25:2181,linux26:2181


#網路執行緒數量


num.network.threads=3 (預設)


#zookeeper每6秒監視kafka是否還活著


zookeeper.connection.timeout.ms=6000（預設）


#注意先啟動zookeeper


zkserver.sh start


#kafka目錄下


./bin/kafka-server-start.sh $kafka_home/config/server.properties & 列印日誌啟動


./bin/kafka-server-start.sh -daemon $kafka_home/config/server.properties & 不列印日誌啟動


#選擇乙個節點執行,建立乙個topic:blb   注：localhost=》linux24


kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic blb


#檢視是否建立成功


kafka集群搭建
安裝zookeeper kafka自帶了zookeeper，建議還是用外部的zk集群，搭建步驟如下 準備3臺機器，假設我們叫c1 c2 c3，ip分別為ip1 ip2 ip3 將附件zookeeper 3.4.6.tar.gz分別拷貝至3臺機器 c1機器上解壓zookeeper 3.4.6.tar....


kafka 集群搭建
1 前置條件 安裝jdk zookeeper 集群搭建 wget tar xzf kafka 2.11 0.10.2.1.tgz 3 修改 config server.properties 三個地方 1 broker.id 要對上 log.dirs 下 meta.properties broker....


kafka集群搭建
1 上傳安裝包 把安裝包上傳到伺服器 put r d kafka 2.11 0.8.2.0.tgz 2 解壓縮安裝包 3 配置kafka環境變數 vim etc profile export path path kafka home bin 重新整理策略 source etc profile 4 修...